springboot框架中使用java操作kafka获取数据 |
您所在的位置：网站首页 › java读取kafka数据到控制台 › springboot框架中使用java操作kafka获取数据 |
|
因为项目里面我只写了从kafka获取数据,所以这里就贴出我的代码来供有需要的读者参考,至于如何写kafka的操作,只有等我研究后再写出来了.并且网上有大量的例子还是可以的 第一种方法,这种方法更繁琐点.第二种相对简单点.我使用的是springboot工程 引入jar包 org.apache.kafka kafka_2.10 0.8.2.1 package com.economic.system.aggregation.common.utils; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Properties; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import kafka.consumer.Consumer; import kafka.consumer.ConsumerConfig; import kafka.consumer.KafkaStream; import kafka.javaapi.consumer.ConsumerConnector; import org.springframework.boot.CommandLineRunner; import org.springframework.core.annotation.Order; import org.springframework.stereotype.Component; /** * 随项目一起启动,项目启动时连接kafka * @author yhy * */ @Component//这个注解可以让项目启动后,就执行这个类,要实现CommandLineRunner接口 @Order(value = 1) public class KafkaConfiguration implements CommandLineRunner { /** groupId*/ private String GROUP_ID = "eosp"; /** topic*/ // @Value("${kafka.topic}") private String TOPIC = "netcompany"; /** 消费者个数*/ private int TOPIC_COUNTMAP = 1;//可以通过topic分区个数来配置,消费者个数要 |
今日新闻 |
推荐新闻 |
| CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |