產生MSG一個話題A和我需要的是我想要做的改變味精並希望將它發送到另一個話題B I創造了製片人,我想卡夫卡流要做到這一點,但不知道是它是一個正確的方式或不是。如果它需要Kafka流,那麼請分享一下應該寫的代碼?如何修改一個kafka主題的消息並使用java發送給另一個kafka主題?
0
A
回答
0
3
有很多選擇你如何能夠做到這一點。
卡夫卡的流API是一種可能與你不添加一個新的依賴到項目的優勢。就像程序應該這樣做一樣簡單的stream.map(...).to(...)
。退房的文檔和示例的詳細信息:
你甚至可以只使用純KafkaConsumer
和KafkaProducer
得到這個工作(但使用卡夫卡的流API似乎更比這更自然)。
當然,你也可以使用Apache弗林克,Apache的風暴,阿帕奇頂點,蒼鷺(或者Apache的星火)流處理框架 - 肯定的,也有別人了。該程序的寫法同上面所描述的一樣簡單。但是您需要設置一個處理羣集來爲您的流處理框架部署您的作業。
+0
@anzzý我想知道你爲什麼恢復接受這個答案嗎?你能解釋爲什麼嗎? –
相關問題
- 1. Spark Streaming + Kafka:如何從kafka消息檢查主題名稱
- 2. Kafka和Docker:將Kafka消息推送給另一個Docker消費者
- 3. 發送到kafka主題時序列化消息的錯誤
- 4. 如何將主題從kafka集羣複製到另一個kafka集羣?
- 5. pipelinedb消費kafka主題
- 6. Apache Kafka主題分區消息處理
- 7. 無法讀取Kafka主題avro消息
- 8. 從kafka到錯誤的另一個kafka主題的Apache駱駝路由
- 9. Apache Kafka如何將消息發送給多個消費者組?
- 10. 如何使用kafka連接將kafka主題下載到oracle中
- 11. Kafka Streams:使用相同的`application.id`來消費多個主題
- 12. 從Spring Kafka發送消息給Angular
- 13. 在kafka上寫同一主題
- 14. Kafka:多個獨立消費者羣體可以消費一個主題嗎?
- 15. 如何刪除apache中的主題kafka
- 16. 爲kafka主題配置ACL
- 17. 事件vs主題Apache Kafka
- 18. 如何從Apache Spark向Kafka發送訂單主題
- 19. 在Rust消費者中消費多個Kafka主題
- 20. Kafka的Spark流:如何從Kafka consumer DStream獲取主題名稱?
- 21. 如何發送消息到Android主題
- 22. 使用jmx顯示器kafka主題
- 23. Kafka生產者消息在EC2主題中不可用linux
- 24. 如何永久刪除kafka主題?
- 25. Kafka Producer Java API不會將消息分發到所有主題分區
- 26. 春季Kafka單一生產者的多個主題
- 27. Kafka:從主題消耗第一條消息時間歇性緩慢
- 28. logstash輸出到kafka - 消息中的主題數據
- 29. 從spark中的kafka消息中獲得主題
- 30. KafkaProducerException上發送消息到一個主題卡夫卡生產
我會用卡夫卡流了點。 –