今天学习了kafka命令行、生产者、broker、消费者就这些内容写一个实践日志
实践日志:学习Kafka命令行、生产者、broker、消费者
今天我开始学习Kafka的基本概念和命令行操作。首先,我了解到Kafka是一个分布式流数据处理平台,可以用于发布和订阅流式数据,以及进行实时数据分析。接着,我学习了一些常用的Kafka命令行操作。
首先,我使用命令行创建了一个Kafka主题(topic):
bin/kafka-topics.sh --create --topic my_topic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1
这个命令创建了一个名为"my_topic"的主题,设置了1个分区和1个复制因子。
接下来,我使用命令行创建了一个生产者(producer):
bin/kafka-console-producer.sh --topic my_topic --bootstrap-server localhost:9092
这个命令创建了一个可以向"my_topic"主题发送消息的生产者。
我尝试发送了一些消息,并观察到它们被成功写入Kafka集群。
然后,我使用命令行创建了一个消费者(consumer):
bin/kafka-console-consumer.sh --topic my_topic --bootstrap-server localhost:9092 --from-beginning
这个命令创建了一个可以从"my_topic"主题消费消息的消费者,并从最早的消息开始消费。
我观察到消费者成功接收到了之前发送的消息,并将其打印出来。
最后,我学习了如何启动和停止Kafka broker。我使用以下命令启动了一个单节点的Kafka broker:
bin/kafka-server-start.sh config/server.properties
我观察到Kafka broker成功启动,并且我可以使用前面学到的生产者和消费者命令与其进行交互。
总结起来,今天的学习内容主要包括了Kafka命令行操作、创建生产者和消费者、创建主题以及启动和停止Kafka broker。通过实践操作,我对Kafka的基本概念和使用有了更深入的了解,为以后的学习和应用奠定了基础
原文地址: http://www.cveoy.top/t/topic/h8d1 著作权归作者所有。请勿转载和采集!