包含java与kafka的词条

本篇文章给大家谈谈java与kafka，以及对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

• 1、java工程kafka传递自定义对象，消费端获取到的是null
• 2、java客户端使用kafka时什么情况下使用kafka client和spring kafka？
• 3、Java使用kafka发送消息没有生效

java工程kafka传递自定义对象，消费端获取到的是null

3. 启服务

3.1 启zookeeper

启zk两种式第种使用kafka自带zk

bin/zookeeper-server-start.sh config/zookeeper.properties

另种使用其zookeeper位于本机位于其址种情况需要修改config面sercer.properties面zookeeper址

例zookeeper.connect=10.202.4.179:2181

3.2 启 kafka

bin/kafka-server-start.sh config/server.properties

4.创建topic

bin/kafka-topics.sh --create --zookeeper 10.202.4.179:2181 --replication-factor 1 --partitions 1 --topic test

创建名testtopic副本区

通list命令查看刚刚创建topic

bin/kafka-topics.sh -list -zookeeper 10.202.4.179:2181

5.启producer并发送消息启producer

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

启发送消息

比

test

hello boy

按Ctrl+C退发送消息

6.启consumer

bin/kafka-console-consumer.sh --zookeeper 10.202.4.179:2181 --topic test --from-beginning

启consumerconsole看producer发送消息

启两终端发送消息接受消息

都行查看zookeeper进程kafkatopic步步排查原吧

java客户端使用kafka时什么情况下使用kafka client和spring kafka？

spring-kafka 是基于 java版的 kafka client与spring的集成，提供了 KafkaTemplate，封装了各种方法，方便操作

所以你使用spring的情况下，可以用spring-kafka，当然直接用kafka client也行

Java使用kafka发送消息没有生效

一般消息发不出去很大可能都是配置或环境的问题

1、排查环境是否有问题，zookeeper节点是否存活，kafka节点是否存活，通过命令行的方式能否发出去消息（使用kafka-console-producer.sh）,如果通过命令行都发不出去那就是集群的问题了。

2、网络问题，调用机器和集群之间网络是否通畅

3、调用时配置的host、port和集群中配置的是否一致，是否需要使用主机名而不是ip

4、客户端api版本是否和服务端差别太大导致不兼容

5、防火墙问题，关闭集群的防火墙实时

诸如此类，可能性太多就不一 一列举了。

你这既然有打印堆栈，如果报错肯定有异常信息的，可能卡住的时间比较长，耐心等待吧，祝你早日解决bug。

关于java与kafka和的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。