下载建网站,主题字体wordpress,管理者的七项基本能力,网站开发要学哪些知识问题#xff1a;项目中用到kafka作为消息中间件#xff0c;因为现在是开发阶段#xff0c;试了一次没问题之后就没在管#xff0c;今天又要测试kafka相关功能#xff0c;发现消息发送者能够正常发送消息#xff0c;但是消费者怎么也就收不到数据。然后经过各种百度进行了…问题项目中用到kafka作为消息中间件因为现在是开发阶段试了一次没问题之后就没在管今天又要测试kafka相关功能发现消息发送者能够正常发送消息但是消费者怎么也就收不到数据。然后经过各种百度进行了如下的一系列操作终于可用了
解决方法
首先停止kafka 进入到kafka的bin目录下停止kafka ./kafka-server-stop.sh …/config/server.properties查看server.properties命令看logdir的目录换个目录或者删除目录中的数据 vi server.properties停止zookeer进入到zookeeper 的bin目录下执行 ./zkServer.sh stop同理查看zookeeper配置文件修改dataDir的路径或者删除目录中的数据 vi zoo.cfg(conf目录下的)重启zookeeper进入到zookeeper 的bin目录下执行 ./zkServer.sh start重启kafka进入到kafka的bin目录下执行 ./kafka-server-start.sh …/config/server.properties 查看kafka启动是否有错误如果没有错误以后台方式执行 ./kafka-server-start.sh -daemon …/config/server.properties
记录几个常用命令
创建主题./kafka-topics --zookeeper.sh localhost:2181 --create --topic test123 --partitions 2 --replication-factor 1查看主题./kafka-topics --zookeeper.sh localhost:2181 --list发送消息./kafka-console-producer.sh --broker-list localhost:9092 --topic test123消费消息./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test123 --from-beginning查看消息消费./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group groupname --describe 虽然问题解决了但是kafka内部原理根本不了解在这立个flag学习kafka
