Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Duplicate
-
0.10.0.0
-
None
-
None
Description
The console producer drops data when if the process exits too quickly. I suspect that the shutdown hook does not call close() or something goes wrong during that close().
Here's a simple to illustrate the issue:
export BOOTSTRAP_SERVERS=localhost:9092 export TOPIC=bar export MESSAGES=10000 ./bin/kafka-topics.sh --zookeeper localhost:2181 --create --partitions 1 --replication-factor 1 --topic "$TOPIC" \ && echo "acks=all" > /tmp/producer.config \ && echo "linger.ms=0" >> /tmp/producer.config \ && seq "$MESSAGES" | ./bin/kafka-console-producer.sh --broker-list "$BOOTSTRAP_SERVERS" --topic "$TOPIC" --producer-config /tmp/producer.config \ && ./bin/kafka-console-consumer.sh --bootstrap-server "$BOOTSTRAP_SERVERS" --new-consumer --from-beginning --max-messages "${MESSAGES}" --topic "$TOPIC"
Attachments
Issue Links
- duplicates
-
KAFKA-3129 Console producer issue when request-required-acks=0
- Reopened
- links to