Hi
We are using kafka 0.10.2 and recently got following error:
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for 
taz_data_info-0: 270120 ms has passed since batch creation plus linger time

The producer configuration is as follows:
         acks: all
          auto.complete: false
          bootstrap.servers: ...
          key.serializer: org.apache.kafka.common.serialization.StringSerializer
          retries: 2147483647
          type: Producer
          value.serializer: ...
Other configurations are defaults
We've tried to understand where this 270 seconds are comming from and failed to 
find something connected. 
According to 
https://cwiki.apache.org/confluence/display/KAFKA/KIP-91+Provide+Intuitive+User+Timeouts+in+The+Producer
 it might happen in "Await send" step, but I haven't found anything on broker 
logs

This is very low volume topic with only 1 partition with RF 3.

Any ideas will be highly appreciated
Igor.

Reply via email to