我已经创建了一个生产者，产生味精一个主题a和我的需要是我想做的改变，味精，并希望把它发送到另一个主题b，我试图这样做Kafka流，但不确定是一个正确的方式或不。如果它需要Kafka流，那么请分享应该写什么代码？
um6iljoc1#
有很多种选择，你可以这样做。kafka的streamsapi是一种可能性，它的优点是不需要向项目中添加新的依赖项。很简单 stream.map(...).to(...) 因为程序应该这样做。查看文档和示例了解更多详细信息：http://docs.confluent.io/current/streams/index.htmlhttps://github.com/confluentinc/examples你甚至可以用普通的 KafkaConsumer 以及 KafkaProducer 要做到这一点（但使用kafka的streamsapi似乎比这更自然）。当然，您也可以使用流处理框架，比如apache flink、apache storm、apache apex、heron（或者apache spark）——当然，还有其他的。程序的编写与上面所描述的一样简单。但是您需要设置一个处理集群来为这些流处理框架部署作业。
stream.map(...).to(...)
KafkaConsumer
KafkaProducer
kcrjzv8t2#
您应该考虑使用apachestorm，它将非常适合您的需要。我用过它，它做得很好，凝胶像牛奶中的水与Kafka。它也很容易实现。祝你好运
2条答案
按热度按时间um6iljoc1#
有很多种选择，你可以这样做。
kafka的streamsapi是一种可能性，它的优点是不需要向项目中添加新的依赖项。很简单
stream.map(...).to(...)因为程序应该这样做。查看文档和示例了解更多详细信息：http://docs.confluent.io/current/streams/index.html
https://github.com/confluentinc/examples
你甚至可以用普通的
KafkaConsumer以及KafkaProducer要做到这一点（但使用kafka的streamsapi似乎比这更自然）。当然，您也可以使用流处理框架，比如apache flink、apache storm、apache apex、heron（或者apache spark）——当然，还有其他的。程序的编写与上面所描述的一样简单。但是您需要设置一个处理集群来为这些流处理框架部署作业。
kcrjzv8t2#
您应该考虑使用apachestorm，它将非常适合您的需要。
我用过它，它做得很好，凝胶像牛奶中的水与Kafka。它也很容易实现。
祝你好运