kafka的版本问题

问题描述：项目中pom.xml关于kafka的依赖为如下所示：

<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka_2.11</artifactId><version>1.0.0</version>
</dependency>

如果在项目中出现了kafka.javaapi.consumer.ConsumerConnector，则在引用ConsumerConnector类时会有如下提示：

kafka.javaapi.consumer.ConsumerConnector' is deprecated

解决办法：出现该问题的主要原因为ConsumerConnector类为kafka低版本中创建Consumer的接口，因此如果想使用低版本中的kafka可更换低版本的kafka依赖，低版本的依赖引入参考示例如下：

<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka_2.9.2</artifactId><version>0.8.1.1</version><exclusions><exclusion><artifactId>jms</artifactId><groupId>javax.jms</groupId></exclusion><exclusion><artifactId>jmxtools</artifactId><groupId>com.sun.jdmk</groupId></exclusion><exclusion><artifactId>jmxri</artifactId><groupId>com.sun.jmx</groupId></exclusion></exclusions>
</dependency>

旧版本producer生成数据的参考示例：

import java.util.*;import kafka.javaapi.producer.Producer;
import kafka.producer.KeyedMessage;
import kafka.producer.ProducerConfig;public class SyncProduce {public static void main(String[] args) { Properties props = new Properties();props.put("metadata.broker.list", "ip1:port1,ip2:port2,ip3:port3");props.put("serializer.class", "kafka.serializer.StringEncoder");//kafka.serializer.DefaultEncoderprops.put("partitioner.class", "kafka.producer.partiton.SimplePartitioner");//kafka.producer.DefaultPartitioner: based on the hash of the keyprops.put("request.required.acks", "1");//0;  绝不等确认  1:   leader的一个副本收到这条消息，并发回确认 -1：   leader的所有副本都收到这条消息，并发回确认ProducerConfig config = new ProducerConfig(props);Producer<String, String> producer = new Producer<String, String>(config);Random rnd = new Random();for (int i = 0; i < 3; i++) { long runtime = new Date().getTime();  String key = "key" + rnd.nextInt(255); String msg = runtime + "___" + key;KeyedMessage<String, String> data = new KeyedMessage<String, String>("jiketest", key, msg);//            eventTopic, eventKey, eventBodyproducer.send(data);try {Thread.sleep(1000);} catch (InterruptedException ie) {}}producer.close();}
}

kafka的版本问题相关推荐

SpringBoot集成Kafka低版本和高版本
SpringBoot集成Kafka低版本和高版本说明地址低版本SpringBoot集成Kafka代码代码 kafka生产者配置 kafka消费者配置发送消息给kafka的Controller ...
c++排查线程hang住_Kafka学习笔记之kafka高版本Client连接0.9Server引发的血案排查 - 时光飞逝，逝者如斯...
0x00 概述 kafka server虽然原则上是兼容详细的client,但只是高版本的Server端兼容低版本的Client端: 在有高版本Client端连接时,会导致低版本Server集群会ha ...
linux环境安装Kafka最新版本 jdk1.8
文章目录一.环境分布二.实战 1. kafka下载 2. 解压 3. 配置 4. 编写启动脚本 5. 编写关闭脚本 6. 赋予脚本可执行权限 7. 脚本使用案例一.环境分布软件版本 jdk ...
查看安装的kafka的版本的方法
开发kafka的程序时,maven中依赖的kafka版本一定要和服务器安装的kafka版本一致,不然会出现问题,其它的中间件也一样进入kafka安装目录下的libs文件夹下,扫一眼就知道了如果是用 ...
斗转星移 | 三万字总结Kafka各个版本差异
点击上方蓝色字体,选择"设为星标" 回复"资源"获取更多资源大数据技术与架构点击右侧关注,大数据开发领域最强公众号! 暴走大数据点击右侧关注,暴走大数据! ...
Docker系列-安装 kafka 单机版本
一.安装 Zookeeper 下载 zookeeper 镜像 docker pull wurstmeister/zookeeper 启动 zookeeper docker run -d --name ...
kafka开源版本quota限流功能缺陷
1.当前quota维度如下 /config/users/<user>/clients/<client id> /config/users/<user>/client ...
查看kafka的版本
查看kafka中libs包中jar文件的版本号即可 http://stackoverflow.com/questions/27606065/how-to-find-the-kafka-version- ...
Linux安装Kafka单机版本
1.下载kafka Apache Kafka 2.安装kafka 2.1解压kafka [doda@host166 kafka]$ tar zxvf kafka_2.11-2.4.1.tgz 2.2配 ...

kafka的版本问题

kafka的版本问题相关推荐

最新文章

热门文章