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

mybatis配置log4j在控制台打印输出sql语句消息中间件rocketmq kafka activemq rabbitmq zeromq对比选型 git add命令详解 spring kafkatemplate 实现 kafka 发送接受消息案例代码 kafka 控制台生产发送消息测试命令 kafka发送消息失败error when sending message to topic test1 with key null kafka 消息技术概念和原理 spring+kafka 注解实现多个group消费者组 linux badblocks命令 linux chroot命令 linux date命令 linux whereis命令 mysql命令 php ftp 函数向 ftp 服务器发送命令 php ftp 函数向服务器发送 site 命令 php hash 函数生成哈希值（消息摘要）php 网络函数发送原生 http 头 php postgresql 函数测试字段是否为 null php readline 函数读取命令历史解决 php 腾讯企业发送邮件异常SMTP Error: Could not authenticate

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

houyong

admin

admin

admin