反应程序在将所有消息发送到 Kafka 之前提前退出
这是之前反应式 kafka 问题的后续问题(将数据流发送到反应式 kafka 时出现的问题). 我正在尝试使用反应式方法向 kafka 发送一些日志记录.这是使用反应式 kafka 发送消息的反应式代码. 公共类 LogProducer {私人最终 KafkaSender发件人；公共日志生产者(字符串引导服务器){映射props = new HashMap();props.put(Prod
..
reactive-kafka相关内容
反应程序在将所有消息发送到 Kafka 之前提前退出
这是之前反应式 kafka 问题的后续问题(将数据流发送到反应式 kafka 时出现的问题). 我正在尝试使用反应式方法向 kafka 发送一些日志记录.这是使用反应式 kafka 发送消息的反应式代码. 公共类 LogProducer {私人最终 KafkaSender发件人；公共日志生产者(字符串引导服务器){映射props = new HashMap();props.put(Prod
..
Reactive Kafka:使用事务处理一次
最初通过 api 调用触发 1.服务 A 生成 m1 到 topic1(非事务性发送)2.服务B消费topic1并做一些处理(开始发送)3.服务B产生m2到topic2(提交交易)4.服务A消费topic2(开始发送) 这是我的生产者配置: final Mapprops = Maps.newConcurrentMap();props.put(ProducerConfig.BOOTSTRAP_
..
如何将 akka 流 kafka(reactive-kafka)集成到 akka http 应用程序中?
我有一个基本的 scala akka http CRUD 应用程序.相关课程见下文. 我只想在例如创建/更新实体时将实体 ID 和一些数据(作为 json)写入 Kafka 主题. 我正在查看 http://doc.akka.io/docs/akka-stream-kafka/current/producer.html，但我是 scala 和 akka 的新手，不确定如何将它集成到我的
..
Reactor Kafka:恰好一次处理样本
我读过很多文章，其中有许多不同的配置可以实现一次处理. 这是我的生产者配置: final Mapprops = Maps.newConcurrentMap();props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);props.put(ProducerConfig.KEY_SERIALIZER_CLASS_C
..
将所有消息发送到Kafka之前，反应式程序退出得较早
这是先前反应式kafka问题(将数据流量发送到反应式kafka 时发出的问题)的后续问题. 我正在尝试使用反应式方法将一些日志记录发送到kafka.这是使用响应式kafka发送消息的响应式代码. 公共类LogProducer {私有最终KafkaSender发件人公共LogProducer(String bootstrapServers){Map
..
反应性卡夫卡:正好处理一次交易
最初通过api调用触发 1.服务A向主题1产生m1(非事务发送)2.服务B消耗topic1并进行一些处理(开始发送)3.服务B向主题2产生m2(提交TX)4.服务A消耗了topic2(开始发送) 这是我的生产者配置: 最终映射道具= Maps.newConcurrentMap();props.put(ProducerConfig.BOOTSTRAP_SERVERS_CON
..
Reactor Kafka:恰好一次处理样品
我读过许多文章，其中有许多不同的配置可以实现一次处理. 这是我的生产者配置: 最终映射道具= Maps.newConcurrentMap();props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG，bootstrapServers);props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CON
..
如何将Akka Streams Kafka（reactive-kafka）集成到Akka HTTP应用程序中？
我有一个基本的scala akka http CRUD应用程序。 我只想在任何时候（例如，实体）将实体ID和一些数据（如json）写入Kafka主题。创建/更新。 我正在查看 http://doc.akka.io/docs/akka-stream-kafka/current/producer.html ，但对于scala和akka来说是新手，并且不确定如何将其集成到我的应用程序中？
..