Atitit Kafka 使用总结内容 Kafka2.0 50M1 启动要启动zookeeper 先，比ativemp麻烦很多啊1 Kafka生产者 1 Kafka消费者2 2

2024-03-23 22:48:24

Atitit Kafka 使用总结

内容

Kafka2.0 50M1

启动要启动zookeeper 先，比ativemp麻烦很多啊1

Kafka生产者 1

Kafka消费者2

2

Kafka2.0 50M

启动要启动zookeeper 先，比ativemp麻烦很多啊

zookeeper-server-start.bat D:\kafka_2.11-2.1.0\config\zookeeper.properties

// D:\kafka_2.11-2.1.0\bin\windows\kafka-server-start.bat D:\kafka_2.11-2.1.0\config\server.properties

D:\kafka_2.11-2.1.0\bin\windows\kafka-server-start.bat D:\kafka_2.11-2.1.0\config\server.properties

//\\ kafka-server-start.bat D:\kafka_2.11-2.1.0\config\server.properties

Kafka生产者

/**

* Kafka生产者

*/

public class KafkaProducerDemo extends Thread{

public static void main(String[] args) throws InterruptedException, ExecutionException {

Properties props = new Properties();

props.put("bootstrap.servers", "127.0.0.1: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");

String message = "message_" ;

String topic="hello_topic";

Producer producer = new KafkaProducer(props);

//Producer producer =new KafkaProducer(props);

//new Producer (new ProducerConfig(properties));

Future<RecordMetadata> Future_RecordMetadata= producer.send(new ProducerRecord<String, String>(topic, "val332222"));

System.out.println("Sent: " + message);

System.out.println(Future_RecordMetadata.get());

}

Kafka消费者

/**

* Kafka消费者

*/

public class KafkaConsumerCls {

public static void main(String[] args) {

Properties props = new Properties();

props.put("bootstrap.servers", "127.0.0.1:9092");

props.put("group.id", "test");

props.put("key.deserializer", StringDeserializer.class);

props.put("value.deserializer", StringDeserializer.class);

KafkaConsumer<String, String> consumer = new KafkaConsumer<String, String>(props);

consumer.subscribe(Arrays.asList("hello_topic"));

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());

}

}

}

kafka_2.12-1.1.0 生产与消费java实现示例 - cctext - 博客园

Atitit Kafka 使用总结内容 Kafka2.0 50M1 启动要启动zookeeper 先，比ativemp麻烦很多啊1 Kafka生产者 1 Kafka消费者2 2相关推荐

再见了kafka2.0时代，去掉了zk的kafka3.0才是时代新王！
项目初期,对于消息队列,你会选择Kafka.ActiveMQ还是RabbitMQ? 对于这个问题,反向来看,估计很少有人会选择Kafka. 而kafka3.0的诞生彻底扭转了战局! 虽然凭借着高吞吐. ...
Kafka集群安装Version1.0.1(自带Zookeeper)
1.说明 Kafka集群安装,基于版本1.0.1, 使用kafka_2.12-1.0.1.tgz安装包, 其中2.12是编译工具Scala的版本. 而且不需要另外安装Zookeeper服务, 使用Ka ...
kafka中文文档（0.10.0）
kafka中文文档(0.10.0) 作者:链上研发-老杨叔叔时间:2016-07-22 版本:Apache Kafka 0.10.0 (2016年5月底发布) .目录 kafka中文文档0100 目 ...
kafka学习_《从0到1学习Flink》—— Flink 读取 Kafka 数据写入到 RabbitMQ
前言之前有文章 <从0到1学习Flink>-- Flink 写入数据到 Kafka 写过 Flink 将处理后的数据后发到 Kafka 消息队列中去,当然我们常用的消息队列可不止这一种, ...
atitit.js的字符串内容转义 js处理html
atitit.js的字符串内容转义 js处理html 1. js处理html的问题1 2. js的字符串内容转义1 3. 下面的表格列出了其余的特殊字符,这些特殊字符都可以使用反斜杠来添加到 ...
面试题:kafka的ACK参数-1,0,1分别代表的含义
一.kafka的ACK参数-1,0,1分别代表的含义这个acks参数在kafka的使用中,是非常核心以及关键的一个参数,决定了很多东西. Kafka producer有三种ack机制初始化prod ...
kafka集群搭建教程（使用自带的zookeeper）
kafka集群搭建教程(使用自带的zookeeper) 一.kafka简介二.kafka名词解释三.zookeeper与Kafka 四.kafka集群搭建前准备 1.下载 2.检验jdk 3.系统 ...
4.2.10 Kafka源码剖析, 阅读环境搭建, broker启动流程, topic创建流程, Producer生产者流程, Consumer消费者流程,
目录 4.1 Kafka源码剖析之源码阅读环境搭建 4.1.1 安装配置Gradle 4.1.2 Scala的安装和配置 4.1.3 Idea配置 4.1.4 源码操作 4.2 Kafka源码剖析之B ...
kafka消费者如何读同一生产者消息_Kafka消费者生产者实例
为了更为直观展示Kafka的消息生产消费的过程,我会从基于Console和基于Application两个方面介绍使用实例.Kafka是一个分布式流处理平台,具体来说有三层含义: 它允许发布和订阅记录流 ...
Abp v0.18.0 新版本: MVC Module 启动模板
0.18.0将于近期发布, 本文内容针对于0.18.0版本. MVC模块启动模板可用此模板开发基于模块开发最佳实践和约定的可复用应用程序模块 . 它同样适用于开发微服务. 如何开始? 你可以使用A ...

最新文章

热门文章