如何修改一個kafka主題的消息並使用java發送給另一個kafka主題？

Question

產生MSG一個話題A和我需要的是我想要做的改變味精並希望將它發送到另一個話題B I創造了製片人，我想卡夫卡流要做到這一點，但不知道是它是一個正確的方式或不是。如果它需要Kafka流，那麼請分享一下應該寫的代碼？

Answer 1

你應該考慮使用Apache storm，這將是非常適合您的需求。

我已經用它和它確實非常好，凝膠像卡夫卡水牛奶。這也很容易實現。

祝你好運

Answer 2

有很多選擇你如何能夠做到這一點。

卡夫卡的流API是一種可能與你不添加一個新的依賴到項目的優勢。就像程序應該這樣做一樣簡單的stream.map(...).to(...)。退房的文檔和示例的詳細信息：

• http://docs.confluent.io/current/streams/index.html
• https://github.com/confluentinc/examples

你甚至可以只使用純KafkaConsumer和KafkaProducer得到這個工作（但使用卡夫卡的流API似乎更比這更自然）。

當然，你也可以使用Apache弗林克，Apache的風暴，阿帕奇頂點，蒼鷺（或者Apache的星火）流處理框架 - 肯定的，也有別人了。該程序的寫法同上面所描述的一樣簡單。但是您需要設置一個處理羣集來爲您的流處理框架部署您的作業。