Shulou(Shulou.com)06/03 Report--

Create Topic

Kafka-topics.sh-create-bootstrap-server localhost:9092-topic abtest-partitions 2-replication-factor 1

Check what Topic has.

Kafka-topics.sh-list-zookeeper localhost:2181

Producer, writing data in the file to the Kafka producer

Kafka-console-producer.sh-broker-list localhost:9092-topic order_topic < abc.txt

Consumers, from the beginning of the shift, consume data in Topic

Kafka-console-consumer.sh-bootstrap-server localhost:9092-topic order_topic-from-beginning

Reset the Offset of Consumer Group to the latest shift

Kafka-consumer-groups.sh-bootstrap-server localhost:9092-group group_name_1-reset-offsets-topic order_topic-to-latest-execute

View consumer group Consumer Group shift

[homework@test] $kafka-consumer-groups.sh-- bootstrap-server host1:9092 Host2:9092-- describe-- group groupname_1TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-IDorder 5 20781271 20781556-order 1 10553765 10554032 267-order 2 10634508 10634808-order 7 10375128 10375355-- -order 6 10435147 10435467-order 0 10640342 10640643 301-order 3 13762141 13762478 337-order 8 11176468 11176707-order 4 10443088 10443320-

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.