这家伙太懒,什么都没留下
acks=all
你的应答模式是什么?ack=
对!我现在的版本信息:kafka server是:kafka_2.11-1.0.0java kafka-clients:
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>1.0.1</version> </dependency>
之前的版本有遇到,第一次是主题还未创建时,前几条会丢失,你kafka是什么版本呢?
你好,请问下,现在我们springboot有在使用kafka,会动态给一些topic写入消息,但是现在发现一个奇怪的问题:如果这个topic是不存在的话,第一次或者前面几次会写入失败,后面才可以写入成功!很奇怪的。请问你觉得是什么原因呢?谢谢!