文档章节

kafka的helloworld程序

杰仪
 杰仪
发布于 2017/06/20 11:02
字数 134
阅读 58
收藏 0

POM 

        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>0.10.2.0</version>
        </dependency>

 

生产者:

public class KafkaProducerTest {
    private static final Logger LOG = LoggerFactory.getLogger(Mqtt2Kafka.class);

    public static void main(String[] avgs){
        LOG.debug("开始");

        Producer<String, String> producer = new KafkaProducer<>(KafkaParams.getSer9ParamsSender());
        int i=1;
        while (i<=10_0000){
            producer.send(new ProducerRecord<>("test2", 0, null, Integer.toString(i)));
            if (i%1000==0)
                producer.flush();
            i++;
        }
        producer.flush();
        producer.close();
        LOG.debug("结束");
    }
}

消费者:

public class KafkaConsumerTest {

    private static final Logger LOG = LoggerFactory.getLogger(KafkaConsumerTest.class);

    public static void main(String[] avgs) {
        LOG.debug("开始");
        Consumer<String, String> consumer = new KafkaConsumer<>(KafkaParams.getSer9ParamsSender(), new StringDeserializer(), new StringDeserializer());

        consumer.subscribe(Arrays.asList("test2"));

        while (true){

            ConsumerRecords<String, String> poll = consumer.poll(20);
            Iterator<ConsumerRecord<String, String>> iterator = poll.iterator();

            while (iterator.hasNext()){
                ConsumerRecord<String, String> next = iterator.next();
                System.out.println("key:"+ next.key() + "---value:"+ next.value());
            }
        }

    }

}

 

© 著作权归作者所有

上一篇: docker 与tomcat整合
下一篇: storm+kafka集成
杰仪
粉丝 1
博文 52
码字总数 10231
作品 0
成都
私信 提问
Scala入门与进阶(一)- 初始Scala

1.初识Scala 1.1 Scala概述 Scala 是整合了面向对象和函数式边恒的高级编程语言。他的一些静态类型能够帮助我们在一些复制的应用程序里面避免到很多bug,并且他的JVM和JavaScript运行环境可以...

Meet相识_bfa5
2018/07/23
0
0
kafka学习笔记——基本概念与安装

Kafka是一个开源的,轻量级的、分布式的、具有复制备份、基于zooKeeper协调管理的分布式消息系统。 它具备以下三个特性: 能够发布订阅流数据: 存储流数据时,提供相应的容错机制 当流数据到...

Janti
2018/08/08
0
0
iTOP-4412开发板基于Linux-C测试程序的编译和运行

iTOP-4412 开发板可以运行的文件系统很多,在具体的文件系统上实现特定功能前,可 以使用 Linux-C 程序来测试硬件以及驱动。而且这些程序很容易移植到 Android、Qt/E 以及 最小文件系统上。 ...

书白
07/22
13
0
java native方法及JNI实例

1.参考文献: http://blog.csdn.net/youjianbohan_87/article/details/2586375 http://blog.csdn.net/yangjiali014/article/details/1633017 http://blog.chinaunix.net/space.php?uid=74379......

huang19830104
2017/02/13
0
0
OpenWRT开发之——创建软件包(有更新)

试验步骤 为了达到自己编写一个程序打包成ipk,并能在OpenWRT上运行的目的。我在网上找了些学习的资料。 本人参考的是:如何在OpenWRT上做开发 感谢该网友的耐心解答。虽然有现成的步骤,博主...

临峰不畏
2015/05/04
16.9K
2

没有更多内容

加载失败,请刷新页面

加载更多

OpenStack 简介和几种安装方式总结

OpenStack :是一个由NASA和Rackspace合作研发并发起的,以Apache许可证授权的自由软件和开放源代码项目。项目目标是提供实施简单、可大规模扩展、丰富、标准统一的云计算管理平台。OpenSta...

小海bug
昨天
5
0
DDD(五)

1、引言 之前学习了解了DDD中实体这一概念,那么接下来需要了解的就是值对象、唯一标识。值对象,值就是数字1、2、3,字符串“1”,“2”,“3”,值时对象的特征,对象是一个事物的具体描述...

MrYuZixian
昨天
6
0
数据库中间件MyCat

什么是MyCat? 查看官网的介绍是这样说的 一个彻底开源的,面向企业应用开发的大数据库集群 支持事务、ACID、可以替代MySQL的加强版数据库 一个可以视为MySQL集群的企业级数据库,用来替代昂贵...

沉浮_
昨天
6
0
解决Mac下VSCode打开zsh乱码

1.乱码问题 iTerm2终端使用Zsh,并且配置Zsh主题,该主题主题需要安装字体来支持箭头效果,在iTerm2中设置这个字体,但是VSCode里这个箭头还是显示乱码。 iTerm2展示如下: VSCode展示如下: 2...

HelloDeveloper
昨天
7
0
常用物流快递单号查询接口种类及对接方法

目前快递查询接口有两种方式可以对接,一是和顺丰、圆通、中通、天天、韵达、德邦这些快递公司一一对接接口,二是和快递鸟这样第三方集成接口一次性对接多家常用快递。第一种耗费时间长,但是...

程序的小猿
昨天
9
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部