markdown 卡夫卡为初学者

Posted 2021-05-05

# Topics

create topic

`kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 10 --topic ladygagaga`

delete topic

`kafka-topics --zookeeper localhost:2181 --delete --topic ladygagaga`

describe topics

`kafka-topics --zookeeper localhost:2181 --describe`

increase number of partitions (cant decrease)

`kafka-topics --zookeeper localhost:2181 --alter --topic my-topic --partitions 42`

print number of messages in partitions

`kafka-run-class kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic ladygaga --time -1`

# Producer/Consumer

produce messages with keys separated by slash

https://stackoverflow.com/questions/26553412/produce-kafka-message-to-selected-partition

`find . | kafka-console.producer.sh --broker-list localhost:9092 --topic $TOPIC --property parse.key=true --property key.separator=/`

print messages with keys

`./kafka-console-consumer.sh --zookeeper <ZOOKEEPER> --topic <YOUR_TOPIC> --property print.key=true`

# Consumer groups

print messages on topic in consumer group

`kafka-console-consumer --bootstrap-server localhost:9092 --topic ladygaga --property print.key=true --group deinterlacecg`

describe consumer group

`kafka-consumer-groups --bootstrap-server localhost:9092 --describe --group deinterlacecg`


# References
Event Sourcing https://martinfowler.com/eaaDev/EventSourcing.html