Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
[18:32:44] $ docker-compose -f kafka.yml up -d kafka
Creating docker_kafka_1
[18:32:51] $ kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
Created topic "test".
[18:33:35] 127 $ kafka-topics.sh --list --zookeeper localhost:2181
test
[18:33:39] $ export JAVA_TOOL_OPTIONS=-Djava.net.preferIPv4Stack=true
[18:33:53] $ kafka-console-producer.sh --broker-list localhost:9092 --topic test
Picked up JAVA_TOOL_OPTIONS: -Djava.net.preferIPv4Stack=true
trolo
trololol
[2016-07-13 18:34:10,085] ERROR Error when sending message to topic test with key: null, value: 5 bytes with error: Batch Expired (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
[2016-07-13 18:34:12,661] ERROR Error when sending message to topic test with key: null, value: 8 bytes with error: Batch Expired (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
Creating docker_kafka_1
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment