java客户端访问kafka

kafka版本：kafka_2.11-0.11.0.1.tgz

centos7

关闭防火墙：systemctl stop firewalld.service

在kafka中配置文件：

listeners=PLAINTEXT://192.168.80.132:9092

在java创建consumer：

package com.vincent;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;/*** Created with IntelliJ IDEA.* User: vincent* Date: 2017/10/26* Time: 14:39*/
public class Test {public static void main(String[] args) {Properties props = new Properties();props.put("bootstrap.servers", "192.168.80.132: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("test"));while (true) {ConsumerRecords<String, String> records = consumer.poll(100);for (ConsumerRecord<String, String> record : records)System.out.printf("offset = %d, key = %s, value = %s", record.offset(), record.key(), record.value());}}
}

java客户端访问kafka相关推荐

【Java客户端访问Kafka】
我是
java客户端作为kafka消费者测试
[README] 本文主要对 java客户端作为kafka 消费者进行测试, 生产者由 kafka客户端扮演: [1]普通消费者设置消费者组: 重置消费者的offset, 即每次都从最头开始消费(默 ...
java客户端作为kafka生产者测试
[README] 1.本文主要对 java客户端作为kafka 生产者进行测试, 消费者由 centos的kafka命令行线程扮演: 2.消息发送: kafka的生产者采用异步发送消息的方式,在消息发 ...
fastdfs java客户端_FastDFS的Java客户端访问
FastDFS的Java客户端访问: 没前奏,直接上车. 1. 引入依赖: net.oschina.zcx7878 fastdfs-client-java 1.27.0.0 2.在项目resource ...
Java客户端访问HBase集群解决方案(优化)
测试环境:Idea+Windows10 准备工作: <1>.打开本地 C:\Windows\System32\drivers\etc(系统默认)下名为hosts的系统文件,如果提示当前用户 ...
Apache Kafka-初体验Kafka(04)-Java客户端操作Kafka
文章目录操作步骤 Maven依赖生产者消费者操作步骤 Maven依赖核心依赖 kafka-clients <dependency><groupId>org.apach ...
java客户端访问ApiServer(kubernetes-client使用)
前言使用kubernetes-client访问k8s apiserver,直接贴代码了配置类ApiClientConfig(自己根据需要改) package com.pdd.transports. ...
java客户端发消息到kafka
前言下面记录下如何使用kafka的java客户端向kafka的broker发送消息 1.导入maven依赖 <dependency><groupId>org.apache.k ...
Kafka : Kafka入门教程和JAVA客户端使用
目录目录 Kafka简介环境介绍术语介绍消费模式下载集群安装配置命令使用 JAVA实战参考文献 Kafka简介由Scala和Java编写,Kafka是一种高吞吐量的分布式发布订阅消息 ...

java客户端访问kafka

java客户端访问kafka相关推荐

最新文章

热门文章