kafka4
post subtitle
By widehyo
```bash [root@peter-kafka01 ~]# vi producer.config [root@peter-kafka01 ~]# cat !$ cat producer.config enable.idempotence=true max.in.flight.requests.per.connection=5 retries=5 [root@peter-kafka01 ~]# realpath !$ realpath producer.config /root/producer.config [root@peter-kafka01 ~]# /usr/local/kafka/bin/kafka-console-producer.sh –bootstrap-server peter-kafka01.foo.bar:9092 –topic peter-test04 –producer.config /root/producer.config org.apache.kafka.common.config.ConfigException: Must set acks to all in order to use the idempotent producer. Otherwise we cannot guarantee idempotence. at org.apache.kafka.clients.producer.ProducerConfig.maybeOverrideAcksAndRetries(ProducerConfig.java:459)...
[Read More]