[Spark][kafka]kafka 生产者,消费者 互动例子
[Spark][kafka]kafka 生产者,消费者 互动例子
# pwd
/usr/local/kafka_2.11-0.10.0.1/bin
创建topic:
# ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic device_status
WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either, but not both.
Created topic "device_status".
#
查看topic:
# ./kafka-topics.sh --list --zookeeper localhost:2181
device_status
#
生产者生成消息:
# ./kafka-console-producer.sh --broker-list localhost:9092 --topic device_status
消费者获得消息:
# pwd
/usr/local/kafka_2.11-0.10.0.1/bin
# ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic device_status --from-beginning
在生产者窗口输入:
hi, I am producer 然后按回车
在消费者窗口会看到:
hi, I am producer
相关文章
- Kafka vs RocketMQ—— Topic数量对单机性能的影响
- Apache Kafka - How to Load Test with JMeter
- Kafka Streams | 流,实时处理和功能
- docker安装kafka及使用
- centos8安装kafka(单机方式)
- 大数据基础之Spark(9)spark部署方式yarn/mesos
- 大叔问题定位分享(9)oozie提交spark任务报 java.lang.NoClassDefFoundError: org/apache/kafka/clients/producer/KafkaProducer
- 【网址收藏】k8s中部署kafka-eagle
- kafka 0.10.2版本常用命令使用示例
- spark集成kafka数据源
- kafka 0.11 spark 2.11 streaming例子
- 大数据开发笔记(七):Kafka分布式流式处理