我正在尝试将Flume与Kafka集成,我想将本地计算机上的一个文件传递给Flume,然后再传递给Kafka。我想在Kafka Consumer中查看我的文件内容。# Describe the sink a1.sinks.k1.type = org.apache.flume.sink.kafka.KafkaSinksource and sink to the channel a1.si
在异常的应用程序终止并重新启动之后,我的应用程序开始接收来自Kafka队列的旧的、已经处理过的消息。spring.kafka.bootstrap-servers=${kafka.host}:${kafka.port}spring.kafka.consumer.group-id=postfenix
spring