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成神之路。
共有 0 条评论