在Spring Boot with Kafka中,我可以如下设置ConsumerFactory的属性: @EnableKafkapublic class KafkaConsumerConfig= new KafkaStreams(builder.build(), streamsConfiguration); 在使用Spring Cloud Streams和KafkaStreams时,所有属性似乎仅通过资源文件夹中的data2
偶尔,我们的应用程序的一个实例会被合法地杀死,这会导致几轮重新平衡,直到旧节点被替换为止。 at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:804)at org.apache.kafka.streams.processor.internals.StreamThread.run(S