Kafka

# Create a topic
/usr/local/kafka/bin/kafka-topics.sh --bootstrap-server kafka-1:9092 --create --replication-factor 1 --partitions 1 --topic <topic>

# List all topics
/usr/local/kafka/bin/kafka-topics.sh --bootstrap-server kafka-1:9092 --list

# Produce messages
/usr/local/kafka/bin/kafka-console-producer.sh --bootstrap-server kafka-2:9092 --topic test_topic

# Consume messages
/usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka-3:9092 --topic test_topic --from-beginning