kafkajava代码 kafka示例代码

kafka集群测试正常,但是Java连接kafka出现异常,急求大神解答!!!_百度...

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

成都地区优秀IDC服务器托管提供商(创新互联建站).为客户提供专业的四川联通机房服务器托管,四川各地服务器托管,四川联通机房服务器托管、多线服务器托管.托管咨询专线：13518219792

只有在jdk9并且kafka版本在0.x之前的版本才会出现。

Broker：Kafka集群包含一个或多个服务器，这种服务器被称为Broker。Kafka的整体架构如下图所示，典型的Kafka集群包含一组发布消息的Producer，一组管理Topic的Broker，和一组订阅消息的Consumer。

1 启动zookeeper 启动zk有两种方式，第一种是使用kafka自己带的一个zk。bin/zookeeper-server-start.sh config/zookeeper.properties& 另一种是使用其它的zookeeper，可以位于本机也可以位于其它地址。

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

1、很明显是类型转换错误。即Integer 类型不能转成String类型。

2、在运行/调试设置中，编辑配置对话框中有“Main”这个选项卡，我们可以勾选“Stop in main”这个复选框。如果选中，那么在调试一个基于main方法的Java程序时，程序会在main方法第一行位置便停止执行。

3、启动consumer之后就可以在console中看到producer发送的消息了 可以开启两个终端，一个发送消息，一个接受消息。如果这样都不行的话，查看zookeeper进程和kafka的topic，一步步排查原因吧。

4、因此分区实际上是调优Kafka并行度的最小单元。

如何用Java向kafka发送json数据

示例中将向 test-topic 主题发送三条消息。消息消费者 和消息生产者类似，这里用 KafkaConsumer 类来创建一个消息消费者，该类的构造函数入参也是一系列属性值。bootstrap. servers 和生产者一样，表示 Kafka 集群。

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

创建好topic之后，使用Java客户端往kafka发消息，使用confluent client发也可以。

google提供的Genson是一个完全的Java和JSON转换的类库，提供了全面的数据绑定、流操作等。基于Apache 0协议发布。转换结果为 JsonObject对象。

kafka发出消息和接收消息都是基于topic，所以要先创建一个topic，才能向里面发消息。创建topic的脚本：topic创建好了，就可以向里边发送消息了。