在用maven引入kafka客户端时,以如下版本为例,会有两个版本号2.10 , 0.10.1.0 很让人疑惑。
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.10</artifactId>
<version>0.10.1.0</version>
</dependency>
然后在依赖lib下会产生两个jar
2.*版本的是scala客户端,1.*版本的是java客户端 ,两个都可以在java环境中使用,调用方式却有不同
scala版本的producer
val kafkaConfig =KafkaUtils.buildKafkaConfig("kafkahost",9092)val producer =newProducer[String,String](newProducerConfig(kafkaConfig))// ... somewhere in code
producer.send(newKeyedMessage[String,String]("my-topic", data))
java 版本的producer
val kafkaConfig =KafkaUtils.buildKafkaConfig("kafkahost",9092)val producer =newKafkaProducer[String,String](kafkaConfig)// ... somewhere in code
producer.send(newProducerRecord[String,String]("my-topic", data))
到底改用哪种方式呢?原来这两种方式是新老两种api。scala版本是老的api,java版本是新的api。官方推荐使用java版本。
官方解释如下
“We are in the process of rewritting the JVM clients for Kafka. As of 0.8.2 Kafka includes a newly rewritten Java producer. The next release will include an equivalent Java consumer. These new clients are meant to supplant the existing Scala clients, but for compatability they will co-exist for some time. These clients are available in a seperate jar with minimal dependencies, while the old Scala clients remain packaged with the server.”
具体参见:http://kafka.apache.org/082/documentation.html#producerapi
相关推荐
一共包含两个程序,分别是Kafka生产者工具、Kafka消费者工具。 1、使用bootstrap、userName、password连接kafka。 2、可使用text、json格式发送topic消息。 3、异步producer、customer,收发消息畅通无阻。 Kafka...
kafka在windows系统的连接工具客户端。非常好用的kafka可视化工具!!!
kafka客户端和服务以及环境配置,比较详细,跟着做就可以实现卡夫卡发布消息和接收消息,这是一个完整的。net 开发的例子
kafka客户端offset kafka客户端offset kafka客户端offset kafka客户端offset kafka客户端offset kafka客户端offset kafka客户端offset kafka客户端offset kafka客户端offset kafka客户端offset kafka客户端offset ...
kafka客户端手册kafka客户端手册kafka客户端手册kafka客户端手册kafka客户端手册kafka客户端手册kafka客户端手册
kafka客户端管理工具
3/kafka有两类客户端,一类叫producer(消息生产者),一类叫做consumer(消息消费者),客户端和broker服务器之间采用tcp协议连接 4/kafka中不同业务系统的消息可以通过topic进行区分,而且每一个消息topic都会被...
kafka客户端,方便查看提供者和消费者的数据,有关消费者偏移量,一目了然,有二级制和UTF-8模式查看消费者内容 查看消费者组
kafka消息队列 监控界面 内含分区选择,topic选择,消息查看发送。操作简便。直接启动jar即可。
finagle-kafka, 在联网和Finagle中,Apache Kafka 客户端 finagle-kafka联网和Finagle中的Apache Kafka 客户端。概述是 Finagle Kafka 是在网联网客户端和 Twitter的 Finagle 。 它使你能够以更功能的方式处理 Kafka...
kafka可视化客户端
Kafka-php 使用纯粹的 PHP 编写的 kafka 客户端
Kafka客户端开发实例java源码
使用纯粹的PHP 编写的 kafka 客户端kafka-php-master.zip
Kafka Tool是一个用于管理和使用Apache Kafka集群的GUI应用程序。它提供了一个直观的UI,允许用户快速查看Kafka群集中的对象以及存储在群集主题中的消息
使用BoostAsio的C++Kafka客户端库
kafkatool客户端工具,查询kafka中的信息。
姓名lua-resty-kafka-基于cosocket API的ngx_lua的Lua kafka客户端驱动程序目录状态该库仍处于早期开发阶段,并且仍处于试验阶段。描述这个Lua库是ngx_lua nginx模块的Kafka客户端驱动程序: 这个Lua库利用了ngx_lua...
对于java来说有原生的支持,但是对于python来说配置稍微麻烦一些,下面说一下具体的配置过程,confluent kafka模块底层依赖于librdkafka,这是使用c编写的高性能的kafka客户端库,有好多语言的库都是依赖于这个,...
haskell的kafka客户端的(非常谦虚的)开端_Haskell_.zip