Kafka使用Java客户端进行访问的示例代码

本文环境如下：

操作系统：CentOS 6 32位

JDK版本：1.8.0_77 32位

Kafka版本：0.9.0.1(Scala 2.11)

1. maven依赖包

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

2. 生产者代码

package com.lnho.example.kafka;

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerRecord;

import java.util.Properties;

public class KafkaProducerExample {
  public static void main(String[] args) {
    Properties props = new Properties();
    props.put("bootstrap.servers", "master:9092");
    props.put("acks", "all");
    props.put("retries", 0);
    props.put("batch.size", 16384);
    props.put("linger.ms", 1);
    props.put("buffer.memory", 33554432);
    props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
    props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

    Producer<String, String> producer = new KafkaProducer<>(props);
    for(int i = 0; i < 100; i++)
      producer.send(new ProducerRecord<>("topic1", Integer.toString(i), Integer.toString(i)));

    producer.close();
  }
}

3. 消费者代码

package com.lnho.example.kafka;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;

import java.util.Arrays;
import java.util.Properties;

public class KafkaConsumerExample {
  public static void main(String[] args) {
    Properties props = new Properties();
    props.put("bootstrap.servers", "master:9092");
    props.put("group.id", "test");
    props.put("enable.auto.commit", "true");
    props.put("auto.commit.interval.ms", "1000");
    props.put("session.timeout.ms", "30000");
    props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
    props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
    KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
    consumer.subscribe(Arrays.asList("topic1"));
    while (true) {
      ConsumerRecords<String, String> records = consumer.poll(100);
      for (ConsumerRecord<String, String> record : records)
        System.out.printf("offset = %d, key = %s, value = %s\n", record.offset(), record.key(), record.value());
    }
  }
}

4. 执行程序

lib底下需要有：kafka-clients-0.9.0.1.jar log4j-1.2.17.jar slf4j-api-1.7.6.jar slf4j-log4j12-1.7.6.jar

生产者:

复制代码 代码如下:
java -classpath kafka-example-1.0-SNAPSHOT.jar:lib/* com.lnho.example.kafka.KafkaProducerExample

消费者:

复制代码 代码如下:
java -classpath kafka-example-1.0-SNAPSHOT.jar:lib/* com.lnho.example.kafka.KafkaConsumerExample

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# Kafka  # JAVA客户端  # Java客户端访问  # Kafka简单客户端编程实例  # Java Kafka分区发送及消费实战  # 关于Kafka消费者订阅方式  # Springboot集成Kafka进行批量消费及踩坑点  # Kafka消费客户端协调器GroupCoordinator详解  # 大家多多  # 操作系统  # Properties  # ProducerRecord  # util  # public  # void  # static  # KafkaProducerExample  # lnho  # package  # java  # import  # Producer  # KafkaProducer 

相关文章： 全景视频制作网站有哪些,全景图怎么做成网页？  南平网站制作公司,2025年南平市事业单位报名时间？  Python lxml的etree和ElementTree有什么区别  网站制作知乎推荐,想做自己的网站用什么工具比较好？  山东云建站价格为何差异显著？  小型网站建站如何选择虚拟主机？  jQuery 常见小例汇总  网站制作专业公司有哪些,如何制作一个企业网站，建设网站的基本步骤有哪些？  一键制作网站软件下载安装,一键自动采集网页文档制作步骤？  制作网站外包平台,自动化接单网站有哪些？  ,想在网上投简历，哪几个网站比较好？  PHP正则匹配日期和时间(时间戳转换)的实例代码  如何零基础在云服务器搭建WordPress站点？  建站之星安装后界面空白如何解决？  网站按钮制作软件,如何实现网页中按钮的自动点击？  沈阳制作网站公司排名,沈阳装饰协会官方网站？  如何在IIS中配置站点IP、端口及主机头？  阿里云网站制作公司,阿里云快速搭建网站好用吗？  制作农业网站的软件,比较好的农业网站推荐一下？  兔展官网 在线制作,怎样制作微信请帖？  如何通过虚拟主机空间快速建站？  手机网站制作与建设方案,手机网站如何建设？  如何快速搭建二级域名独立网站？  武汉网站如何制作,黄黄高铁武穴北站途经哪些村庄？  建站之星官网登录失败？如何快速解决？  如何选择香港主机高效搭建外贸独立站？  制作充值网站的软件,做人力招聘为什么要自己交端口钱？  哈尔滨网站建设策划,哈尔滨电工证查询网站？  linux top下的 minerd 木马清除方法  css网站制作参考文献有哪些,易聊怎么注册？  高防服务器：AI智能防御DDoS攻击与数据安全保障  成都品牌网站制作公司,成都营业执照年报网上怎么办理？  成都响应式网站开发,dw怎么把手机适应页面变成网页？  制作公司内部网站有哪些,内网如何建网站？  建站一年半SEO优化实战指南：核心词挖掘与长尾流量提升策略  韩国服务器如何优化跨境访问实现高效连接？  临沂网站制作企业,临沂第三中学官方网站？  如何用好域名打造高点击率的自主建站？  建站之星在线版空间：自助建站+智能模板一键生成方案  广州网站建站公司选择指南：建站流程与SEO优化关键词解析  东莞专业制作网站的公司,东莞大学生网的网址是什么？  如何用免费手机建站系统零基础打造专业网站？  一键网站制作软件,义乌购一件代发流程？  建站之星24小时客服电话如何获取？  如何快速建站并高效导出源代码？  北京的网站制作公司有哪些,哪个视频网站最好？  专业制作网站的公司哪家好,建立一个公司网站的费用.有哪些部分,分别要多少钱？  c# 服务器GC和工作站GC的区别和设置  制作网站哪家好,cc、.co、.cm哪个域名更适合做网站？  如何通过虚拟主机快速完成网站搭建？