我们最近实现了kafka，我们正在从单一的代码库走向微服务。Kafka的每个消费者都有自己的微服务。但现在，事情变得有点难以控制了。我们有很多消费者，有时一个消费者也会产生一个事件，而另一个消费者会消费该事件。现在的问题是，当有人要求我解决某个问题，我不知道什么消费者订阅。。。如果不深入研究每一次回购/消费者回购的代码（我们有很多代码，需要花费太长时间），我就无法全面了解目前的情况。
我们能做些什么来从生产者到消费者等方面进行端到端的理解？主要用于故障排除/变更管理。
p、 我们很可能没有“正确的方式”实施Kafka，所以不要羞于直言不讳