Kafka的api总结

生产者api
第一个案例  使用的一个消费者
kafka-console-consumer.sh --bootstrap-server qianfeng01:9092,qianfeng02:9092,qianfeng03:9092 --topic food
先运行idea中的生产者,然后再去集群中国运行一个消费者  查看消费者中的消息

package com.qf.kafka;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 Producer {     public static void main(String[] args) {         Properties

Kafka的api总结最先出现在Python成神之路

版权声明:
作者:dingding
链接:https://www.techfm.club/p/21301.html
来源:TechFM
文章版权归作者所有,未经允许请勿转载。

THE END
分享
二维码
< <上一篇
下一篇>>