packagecom.cisdi.dsp.modules.metaAnalysis.rest.kafka2023;importorg.apache.kafka.clients.producer.*;importorg.apache.kafka.common.serialization.StringSerializer;importjava.time.Duration;importjava.util.Properties;importjava.util.concurrent.E

参数配置bootstrap.servers：该参数用来指定生产者客户端连接Kafka集群所需的broker地址清单，具体的内容格式为host1:port1,host2:port2，可以设置一个或多个地址，中间以

1.发送消息流程1.1整体架构整个生产者客户端由两个线程协调运行，这两个线程分别为主线程和Sender线程（发送线程）。在主线程中由KafkaProducer创建消息，然后通过可能的

在命令行执行：使用console_producer连接kafka服务，发送数据，利用wireshark抓包查看具体的发送过程   头3条是tcp协议的三次握手。握手成功后，第4条开始console_produc

 1，因为mysql版本从5.7提高到8.0 ，需要更改用户配置。createuser'canal'@'%'identifiedby'canal';grantselect,replicationslave,replicationclienton