Kafka client operations

Kafka 客户端相关的命令行操作

消费者组订阅的topic

kafka-consumer-groups --bootstrap-server <kafkahost:port> --group <group_id> --describe

reset topic

需要先停止消费者组的消费

kafka-consumer-groups --bootstrap-server <kafkahost:port> --group <group_id> --topic <topic_name> --reset-offsets --to-earliest # 预览

kafka-consumer-groups --bootstrap-server <kafkahost:port> --group <group_id> --topic <topic_name> --reset-offsets --to-earliest  --execute # 执行

消费消息

kafka-console-consumer.sh --bootstrap-server <kafkahost:port> --group <group_id> --topic <topic_name> --partition <partition_num> --to-offset <offsets> 
	--maximum-length <length> 
	--from-beginning 
	--to-datetime <datetime_string>

推送/生产消息

kafka-console-producer.sh --broker-list <kafkahost:port> --topic <topic_name> #执行后直接输入

Written on July 20, 2020