前言

下面记录下如何使用kafka的java客户端向kafka的broker发送消息

1、导入maven依赖

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

2、发送方式1，直接发送

比如我们提前创建好了一个名为 ”zcy222“的topic，测试的数据将发到这个topic中

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;import java.util.Properties;public class Producer1 {public static void main(String[] args) throws Exception {// 1. 创建 kafka 生产者的配置对象Properties properties = new Properties();// 2. 给 kafka 配置对象添加配置信息：bootstrap.serversproperties

java客户端发消息到kafka相关推荐

原生 Java 客户端进行消息通信
原生 Java 客户端进行消息通信 Direct 交换器 DirectProducer:direct类型交换器的生产者 NormalConsumer:普通的消费者 MulitBindConsumer: ...
java消息通信_原生 Java 客户端进行消息通信
原生 Java 客户端进行消息通信 Direct 交换器 DirectProducer:direct类型交换器的生产者 NormalConsumer:普通的消费者 MulitBindConsumer: ...
服务器向客户机发信息,服务器如何主动给客户端发消息
服务器如何主动给客户端发消息内容精选换一换当出现以下问题时,可以参考本章节排查解决.可以直接访问后端业务,但是无法通过负载均衡访问后端业务.通过私网IP可以访问负载均衡,但是公网IP无法访问负载 ...
java服务器向客户端发消息_java一个简单的客户端向服务端发送消息
java一个简单的客户端向服务端发送消息客户端代码: package com.chenghu.tcpip; import java.io.IOException; import java.io.Ou ...
java tcp发消息给硬件_java – TCP客户端/服务器通信只发送第一条消息？
我在java中设置一个简单的TCP客户端服务器交互. 服务器: 服务器是用Java编写的桌面客户端: import java.io.BufferedReader; import java.io.Dat ...
java 模拟飞秋客户端发消息
package feiQ; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSo ...
java tcp发消息给硬件_服务器可以使用TCP向客户端发送消息吗？
如果您有自定义客户端(例如,不是浏览器中的Web应用程序),则可以根据需要与服务器 Build 纯TCP连接 . 但是,TCP上的每次传输都需要双方正在使用的某种数据格式(通常称为"协议&q ...
udp,tcp软件udp客户端发消息,udp服务器收不到,C#网络编程，多级路由间，UDP发送消息客户端接收不正常？...
udp协议是不需要进行握手连接的,所以你可能需要循环读取试试: //侦听消息 UdpClient receivingUdpClient = new UdpClient(侦听端口); IPEndPoin ...
node服务器给客户端发消息,上的node.js发送消息客户端 - 服务器 - 客户端上socket.io(Sen...
我使用的NodeJS + Socket.IO简单的网页游戏. 有用. 为什么? 这里是我的server.js var app = require('express').createServer(); ...

java客户端发消息到kafka

前言

java客户端发消息到kafka相关推荐

最新文章

热门文章