我在我的项目中使用了ApacheKafka，所以，我有一个制作人来制作一个特定主题的信息。消费者是另一个微服务，它从Kafka那里阅读信息，并将该信息传递给另一个微服务（比如数据）现在，问题是......如果最后一个微服务（数据）不起作用，而消费者试图将消息发送到这个服务，它应该停止从Kafka中阅读，然后在下一次运行时再次重新发送这些消息。有谁知道怎么做到这一点吗？注意-我已尝试启用.auto.commit=false但这并不奏效
vbkedwbf1#
把你的消费者也变成生产者。让你的“最终微服务”从Kafka那里消费，而不是像你现在这样接受服务到服务的请求。或者，使用带有负载平衡器的流程编排来确保最终服务的高可用性，并运行多个示例。
1条答案
按热度按时间vbkedwbf1#
把你的消费者也变成生产者。
让你的“最终微服务”从Kafka那里消费，而不是像你现在这样接受服务到服务的请求。
或者，使用带有负载平衡器的流程编排来确保最终服务的高可用性，并运行多个示例。