0
我有从.mongoDB数据库导出的.bson文件（3.4 GB大小）。 我想通过kafka发送此文件数据并将其保存在cassandra表 有没有人知道如何做到这一点通过kafka （.bson文件的数据作为kafka生产者和cassandra作为接收器） 我知道kafka cassandra接收器和我正在使用它，但我想知道制片人提取.bson数据并将其发送到kafka。.bson文件的数据为Kafka Producer
A
回答
0
为什么不使用MongoDB来源进行Kafka Connect？有几个列出在https://www.confluent.io/product/connectors/
将静态文件带到流上下文感觉不对，除非有一些不可避免的原因。
相关问题
- 1. Kafka Producer行为
- 2. perl Kafka :: Producer，“Kafka :: Exception :: Producer”，“code”，-1000，“message”，“无效的参数
- 3. 提高Kafka Producer的性能
- 4. kafka-console-producer和bash脚本
- 5. 读取Producer中的数据流并推送到Kafka主题
- 6. 如何解决Kafka Producer中的RecordTooLargeException？
- 7. Kafka Producer停止我的代码
- 8. 并行使用Akka Streams Kafka Producer
- 9. 如何使用kafka-avro-console-producer？
- 10. Apache Flume Kafka Producer - 动态生成partition_id/key
- 11. 当kafka Producer被设置为同步时，Kafka Consumer没有被调用
- 12. 选择获取kafka-producer中的主题订阅者数量
- 13. Kafka Spark Streaming Consumer将不会收到来自Kafka Console Producer的任何消息？
- 14. Kafka：如何生成多个传入文件给Kafka？
- 15. 为什么Kafka Producer无法连接到zookeeper获取经纪人元数据而不是连接到经纪人
- 16. 如何在.bson文件中导入数据
- 17. 无法在Intellij中创建Kafka Producer对象
- 18. Kafka Producer 0.9.0性能，大量等待线程
- 19. 使用kafka-producer-perf-test.sh如何在kafka_2.10-0.8.2.0
- 20. CEP Producer - 定时文件适配器
- 21. 将kafka（kafka-python）转储到txt文件
- 22. BSON数据库的简单编辑器
- 23. 为什么Kafka不会删除数据？
- 24. 未初始化的常量BSON ::文件
- 25. C＃producer/consumer/observer？
- 26. mongodb中Moustache.js和bson数据列表
- 27. Spring批处理：从Kafka读取数据并写入文件
- 28. 通过Kafka和Spark消耗大数据
- 29. Apache Camel Restlet Producer Connector
- 30. BSON :: InvalidDocument：无法序列化类用户的目标为BSON
所以，你要读从BSON每个文档/对象汇卡夫卡连接过，再单独成卡夫卡作为单独的邮件？正如你所说，这个问题的Cassandra部分已经解决了。 –