读取数据文件的Kafka生产者
我试图在循环中加载一个数据文件（以检查统计数据），而不是在Kafka中的标准输入。下载Kafka后，我执行了以下步骤：
启动动物园管理员：
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 test
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
Test1
Test2
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
Test1
Test2
共有1个答案
您可以通过cat读取数据文件并将其管道化到kafka-console-producer.sh。
cat ${datafile} | ${kafka_home}/bin/kafka-console-producer.sh --broker-list ${brokerlist} --topic test
-
问题内容： 我正在阅读有关使用私钥加密的IBM教程。我写的代码如下 上面的代码效果很好。我能够看到结果和所有内容。但我想按如下方式进行修改，以便可以将cipherText存储在文件中。然后，另一个程序从文件中读取加密的文本并将其解密。以下是我到目前为止所做的事情，但我不知道如何进行。只是一些有关如何进行的提示会有所帮助。 现在，该程序的工作已经完成。它已成功将加密的字符串写入文件。新程序仅需解密数
-
问题内容： 我有以下格式的文本文件： Details.txt 该文件是.txt文件。我想从该文件中读取课程标题，并打印相应的教科书和教师信息。但是我不确定该遵循什么程序？将信息存储在数组中效率不高！我应该如何进行？注意：我无法更改文件中的信息，因此不应更改！显然，文件将通过以下代码读取： 但是我应该如何根据课程名称，教科书和讲师的标签从该文件中提取数据！ 问题答案： 首先正确地逐行阅读文件，然后搜
-
本文向大家介绍Android读取XML文件中的数据，包括了Android读取XML文件中的数据的使用技巧和注意事项，需要的朋友参考一下 本文实例为大家分享了Android读取XML文件中数据的具体代码，供大家参考，具体内容如下 读取XML中存储的数据。将xmlfile.xml存放在assets文件夹中。在activity_main.xml中创建一个textview，用来显示读取到的数据。 XML文
-
我正在尝试从com包中的CSV文件中读取值。实例但当我使用以下语法运行代码时： 上面写着： java.io.FileNotFoundException： Dataset.csv 我也尝试过使用： 仍然不工作。任何帮助都会很有帮助。谢谢
-
我有一个非常简单的问题：使用Python从txt文件中读取不同条目的最有效方法是什么？ 假设我有一个文本文件，如下所示： 在C中，我会这样做： 用Python做这样的事情最好的方法是什么？以便将每个值存储到不同的变量中(因为我必须在整个代码中使用这些变量)。 提前感谢！
-
我正在尝试编写一个简单的java kafka consumer，使用与中类似的代码读取数据https://github.com/bkimminich/apache-kafka-book-examples/blob/master/src/test/kafka/consumer/SimpleHLConsumer.java. 看起来我的应用程序可以连接，但它无法获取任何数据。请建议。 下面是我在ecli