【文件属性】：
文件名称：kafka-producer
文件大小：24KB
文件格式：ZIP
更新时间：2021-05-01 23:35:19
Java
卡夫卡制片人
用法
用法：配置生产者：
Producer producer = Producer.builder()
.withServers(brokers) // DBC kafka broker names
.withTopic(topic) // an agreed upon kafka-topic
.build();
发送
producer.send("key1", "message"); // kafka key-value pairs, where value will most likely be JSON.
注意：
尝试连接到不存在的服务器是一个错误，并且会抛出KafkaExecption（RuntimeException）
尝试发送到不存在的主题（正在生产中）也会导致RuntimeException。 由于Kafka配置为
【文件预览】：
kafka-producer-master
----pom.xml(4KB)
----Jenkinsfile(2KB)
----LICENSE(34KB)
----src()
--------test()
--------main()
----README.md(1KB)