Java开发中使用Kafka实现客户端程序的方法

Kafka作为流数据平台,为开发者提供了三个客户端,这篇文章主要是利用Kafka的API创建一个生产者和消费者,操作是很简单的,今天云上诗词技术频道小编就为大家带来了Java开发中使用Kafka实现客户端程序的方法,看到最后大家都会感到很惊讶。

一、创建配置类Config

这个类很简单,只是存放了两个常量,一个是话题TOPIC,一个是线程数THREADS

package com.lya.kafka; /** * 配置项 * @author liuyazhuang * */ public class Config { /** * 话题 */ public static final String TOPIC = "wordcount"; /** * 线程数 */ public static final Integer THREADS = 1; }

原创文章,作者:nxyxs,如若转载,请注明出处:http://www.yunshangshici.com/26421.html

(0)
上一篇 2022年6月11日 下午1:35
下一篇 2022年6月11日 下午1:35

相关推荐

返回顶部