如何生成输入数据并将其存储到本地文件中，以及如何使用kafka读取输入生成文件的数据。

Question

为此，我创办了动物园管理员：bin/zookeeper-server-start.sh config/zookeeper.properties

然后是卡夫卡服务器：bin/kafka-server-start.sh config/server.properties

主题：bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic fast-messages

那么文件生成的下一步是什么呢？

Answer 1

您需要解析该文件，并从其中编写一个Kafka生产者。

或者，您可以直接将文件输送到控制台生成器。

如何向卡夫卡制作者写文件

或使用KafkaConnect FileSourceConnector

Answer 2

对于同样的问题，我也提到了另一个链接，我得到了结果。链接是-> https://docs.confluent.io/current/streams/quickstart.html

以下是我遵循的步骤->

步骤1:启动动物园管理员bin/zookeeper-server-start.sh config/zookeeper.properties

步骤2:启动kafka服务器bin/kafka-server-start.sh config/server.properties

步骤3:创建一个名为“快速消息”bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic fast-messages的主题

步骤4:运行生产者kafka-console-producer.sh --broker-list localhost:9092 --topic fast-messages --new-producer < my_file.txt

第五步:消费者聆听：

/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic fast-messages --from-beginning