首页 > 其他分享 >2. 新版本生产者代码--建议使用的版本

2. 新版本生产者代码--建议使用的版本

时间:2022-09-07 17:13:51浏览次数:62  
标签:producer -- kafka 生产者 版本 props put org

1. 开启进程

[node123]systemctl stop firewalld

[node123]zkServer.sh start

[node123]kafka-server-start.sh /opt/app/kafka-0.11.0.0/config/server.properties &

[node1]kafka-console-consumer.sh --zookeeper node1:2181 --topic demo

2. java导入依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.example</groupId>
    <artifactId>kafkacode</artifactId>
    <version>1.0-SNAPSHOT</version>

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

        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka_2.12</artifactId>
            <version>0.11.0.0</version>
        </dependency>
    </dependencies>
</project>

3. java代码

package new_out;

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

import java.util.Properties;

// 新版本生产者代码--建议大家使用的版本
public class NewProducer {
    public static void main(String[] args) {
        Properties props = new Properties();
        // Kafka服务端的主机名和端口号
        props.put("bootstrap.servers", "192.168.200.111:9092, 192.168.200.112:9092, 192.168.200.113:9092");
        // 等待所有副本节点的应答
        props.put("acks", "all");
        // 消息发送最大尝试次数
        props.put("retries", 0);
        // 一批消息处理大小
        props.put("batch.size", 16384);
        // 请求延时
        props.put("linger.ms", 1);
        // 发送缓存区内存大小
        props.put("buffer.memory", 33554432);
        // key序列化
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        // value序列化
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

        KafkaProducer<Object, Object> producer = new KafkaProducer<Object, Object>(props);
        for (int i = 0; i < 100; i++) {
            producer.send(new ProducerRecord<Object, Object>("demo", "hello--"+i));
        }
        // 必须有下面的语句才行,二选一
        // producer.commitTransaction();
        producer.close();
    }
}

标签:producer,--,kafka,生产者,版本,props,put,org
From: https://www.cnblogs.com/jsqup/p/16665760.html

相关文章

  • 科目二阅读版
    倒车入库倒库先是右倒入,向右打死等入库;入库回正再微调,微调半圈就可以;出库向左转到底,保持不动换倒档;原路返回正入库,向右出库就完成。侧方位停车侧方停稳换倒档,到点向右打到......
  • EasyCVR云端录像模块无法进行下载是什么原因?该如何解决该问题?
    EasyCVR平台支持海量视频汇聚管理,能兼容多类型的设备接入,可覆盖市面上大多数的视频源设备,包括各种IPC、NVR、视频服务器、单兵设备、编码器设备等。平台也可支持多协议接入......
  • DM8主备集群搭建
    1.1、守护进程守护进程(dmwatcher)是DM数据守护系统不可或缺的核心部件,是数据库实例和监视器之间信息流转的桥梁。数据库实例向本地守护进程发送信息,接收本地守护进程的消......
  • 《安富莱嵌入式周报》第281期:Keil Studio发布VSCode插件,微软嵌入式IDE升级,开源穿戴手
    往期周报汇总地址:http://www.armbbs.cn/forum.php?mod=forumdisplay&fid=12&filter=typeid&typeid=104 上周更新一期视频教程:USB应用实战视频教程第2期:玩点高级的硬核......
  • C - Friend-Graph HDU - 6152 三元环 & 拉姆齐定理
    原题链接题意:判断图和补图是否含有三元环拉姆齐定理拉姆齐定理:在>=6个点的完全图中,用红蓝两色染色,一定存在一个红色或者蓝色的三角形。所有n>=6的话直接输出badte......
  • 4.JS内部对象
    4.内部对象标准对象4.1Date typeof123 'number' typeof'123' 'string' typeoftrue 'boolean' typeofNaN 'number' typeof[] 'object' typeof{} 'o......
  • 开源协同OA开发平台:OA办公系统内部的云笔记
    目前市面上有许许多多的云笔记产品,所谓云笔记,主要的作用就是记录个人的备忘需求,比如每天的日程安排、突如其来的灵感、生活笔记等等,只需要一个账号,就可以多平台通用。除了......
  • letcode算法--20.有效的括号
    给定一个只包括'(',')','{','}','[',']' 的字符串s,判断字符串是否有效。有效字符串需满足:左括号必须用相同类型的右括号闭合。左括号必须以正确的顺序闭合。每个右括号都......
  • SAP 角色如何传输
    1PFCG创建角色  2,utilities-----masstransport   3,输入角色。(注意模板角色与子角色的区别)  4,执行后会要求输入请求号.。  5,SE10释放请求号。......
  • linux 信号概念
    信号的概念信号(Signal)是一种软件中断,比如Ctrl+C的退出命令实质上就是使用了信号。信号在Linux操作系统中提供了一种处理异步事件的方法,可以很好地在多个进程之间进行同步......