Kafka — distributed streaming platform.
1# Commands2kafka-topics.sh --create --topic my-topic --bootstrap-server localhost:9092 --partitions 33kafka-topics.sh --list --bootstrap-server localhost:90924kafka-console-producer.sh --topic my-topic --bootstrap-server localhost:90925kafka-console-consumer.sh --topic my-topic --bootstrap-server localhost:909267# Consumer groups8kafka-consumer-groups.sh --list --bootstrap-server localhost:90929kafka-consumer-groups.sh --describe --group my-group --bootstrap-server localhost:90921011# Offsets12kafka-consumer-groups.sh --reset-offsets --to-earliest --group my-group --topic my-topic --execute
1# docker-compose.yml2zookeeper:3 image: confluentinc/cp-zookeeper:7.4.04 environment:5 ZOOKEEPER_CLIENT_PORT: 218167kafka:8 image: confluentinc/cp-kafka:7.4.09 depends_on:10 - zookeeper11 environment:12 KAFKA_BROKER_ID: 113 KAFKA_ZOOKEEPER_CONNECT: zookeeper:218114 KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:909215 KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
Advantages: