dataplatform/kafka repository overview

The following commands should be run inside Kafka container. From development machine run docker exec -it vagrant_kafka0_1 bash to get into Kafka container

⁠View arrival messages rate

bin/kafka-run-class.sh kafka.tools.JmxTool --object-name 'kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec' --reporting-interval 1000

⁠Consume messages from Kafka

Read all messages in "ody.events" topic and print them to console. This is useful for testing purpose docker exec -it vagrant_kafka_1 sh -c 'bin/kafka-console-consumer.sh --zookeeper zookeeper1:2181/kafka --topic ody.events --from-beginning'