方式一:
基于maven的java kafka的生产者和消费者直接的通信:
配置本地的zookeeper服务,同时将本地的kafka服务启动。
使用mvn archetype:generate 生成 maven项目,并引入对应的pom依赖:
在producer项目中配置kafka相关的连接数据,初始化数据写在类的构造函数中:
java consumer接受kafka配置
方式一:
基于maven的java kafka的生产者和消费者直接的通信:
配置本地的zookeeper服务,同时将本地的kafka服务启动。
使用mvn archetype:generate 生成 maven项目,并引入对应的pom依赖:
在producer项目中配置kafka相关的连接数据,初始化数据写在类的构造函数中:
java consumer接受kafka配置