kafka 控制台生产发送消息测试命令

kafka | 2019-09-19 08:54:44

1.查看topic列表

./kafka-topics.sh --list --zookeeper master:2181

查看topic详情

#./kafka-topics.sh --zookeeper master:2181 --topic designTopic --describe
Topic:designTopic	PartitionCount:1	ReplicationFactor:1	Configs:
	Topic: designTopic	Partition: 0	Leader: 1002	Replicas: 1002	Isr: 1002

2.创建topic

./kafka-topics.sh --create --zookeeper master:2181 --replication-factor 1 --partitions 1 --topic testMyTopic

3.创建生产者

./kafka-console-producer.sh --broker-list slave203:6667 --topic designTopic

4.创建消费者

./kafka-console-consumer.sh -zookeeper master:2181 --topic designTopic

新版kafka ./kafka-console-consumer.sh --bootstrap-server slave1:9092 --topic designTopic

登录后即可回复登录 | 注册

houyong

从头开始消费全部测试

kafka-console-consumer.sh --bootstrap-server 192.168.1.3:9092 --topic mykafkaTopic --from-beginning
admin

记录一下 kafka 启动命令：nohup ./kafka-server-start.sh ../config/server.properties &
admin

kafka版本不同，消费者的创建方式不一样，老版用zk，新版用bootstrap-server，导致编程的方式也不一样，这是我遇到的比较坑的消费不到信息的原因。
admin

在新版的kafka不能使用zk,而要使用bootstrap-server

./kafka-console-consumer.sh --bootstrap-server slave1:9092 --topic designTopic

否则会报错：

Using the ConsoleConsumer with old consumer is deprecated and will be removed in a future major rel

消息中间件rocketmq kafka activemq rabbitmq zeromq对比选型 linux tar命令参数详解 spring kafkatemplate 实现 kafka 发送接受消息案例代码 kafka 控制台生产发送消息测试命令 kafka发送消息失败error when sending message to topic test1 with key null kafka如何删除topic kafka 消息技术概念和原理 linux ar命令 linux chgrp命令 linux crontab命令 linux du命令 linux fbset命令 linux ftpshut命令 linux hdparm命令 linux let 命令 linux lpr命令 php ftp 函数连续获取／发送文件（non blocking）php ftp 函数向 ftp 服务器发送命令 php ftp 函数向服务器发送 site 命令 php svn 函数将修改的本地文件副本发送至版本库

kafka 控制台生产发送消息测试命令

houyong

admin

admin

admin