Skip to content

Instantly share code, notes, and snippets.

@virtimus
Last active January 22, 2018 01:01
Show Gist options
  • Save virtimus/ea1430c94a4a4ffd4eea23ac51a36c58 to your computer and use it in GitHub Desktop.
Save virtimus/ea1430c94a4a4ffd4eea23ac51a36c58 to your computer and use it in GitHub Desktop.
i3c - kafka - test of message producer/consumer
ln -s /i3c/i3c/i3c.sh /i
  • build/start zookeeper & kafka:
/i rebuild zookeeper
/i rerun zookeeper
/i rebuild kafka
/i rerun kafka
  • build/start portainer
/i rebuild portainer
/i rerun portainer
  • open portainer (port 9000)
  • Containers > kafka > Console
cd /opt/kafka
bin/kafka-topics.sh --create --zookeeper zookeeper.i3c.l --replication-factor 1 --partitions 1 --topic test
bin/kafka-topics.sh --list --zookeeper zookeeper.i3c.l
bin/kafka-console-producer.sh --broker-list kafka.i3c.l:9092 --topic test
  • enter a message
  • Containers (right click new browser page to open separate console) > kafka > Console
cd /opt/kafka
bin/kafka-console-consumer.sh --bootstrap-server kafka.i3c.l:9092 --topic test --from-beginning
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment