kafka

Kafka

Refer to Go社区主流Kafka客户端简要对比

This blogpost aims "write log to Kafka" as its scenario.

Manual commands

From Kafka quick start

docker-compose up -d

# Create a topic
docker exec broker \
kafka-topics --bootstrap-server broker:9092 \
--create \
--topic quickstart

# Write message to topic
docker exec --interactive --tty broker \
kafka-console-producer --bootstrap-server broker:9092 \
--topic quickstart

# Read message
docker exec --interactive --tty broker \
kafka-console-consumer --bootstrap-server broker:9092 \
--topic quickstart \
--from-beginning

docker-compose down