一、上一节讲了kafka的安装，这节讲一下Java开发kafka程序。所需jar包https://download.csdn.net/download/hezhihuahzh/10647732 可下载。二、写代码前先大概说一下kafka的生产发送和接收消费的细节。       1、Consumer Group：一个Consumer Group包含多个consumer, 这个是...

一、上节讲到Java程序发送接收简单的String类型数据，那么发送接收对象怎么办呢？下面具体说一下。二、要发送对象，首先得有个对象，那么先创建一个对象类，暂且定义成SQLData，发送对象要序列化，import java.io.Serializable;public class SQLData implements Serializable{private static fin...

一、前几节讲了简单的数据发送接收，忘了说一个点，就是producer发送数据的时候怎么保证数据成功发送到kafka服务器上。org.apache.kafka.clients.producer.Producer的send（）方法有三个重载，其中一个如下：producer.send(new ProducerRecord<String, Object>(TOPIC, data

微信小程序码Java生成