产生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上发送消息到一个主题卡夫卡生产
我会用卡夫卡流了点。 –