docker - Kafka docker镜像中的可配置延迟

Question

使用两个不同的卡夫卡事件(每100个事件中有99次以“正确”顺序到达)时，我在代码中发现了竞争情况。我已修复该错误，我想证明一下。
对于一个我愿意在消费者代码上加上Thread.sleep()的问题，拥有本地kafka经纪人可以配置不同的标准来引入延迟，这真是太好了。如果您遇到过类似的情况，则类似于Mountebank为您提供的HTTP服务。
我根据需要通过将应用程序的Docker镜像与db / kafka / http服务器docker镜像一起部署来执行黑盒测试。拥有一个可配置的Docker Kafka镜像真是太好了，您知道吗？
提前致谢。

Answer 1

每个主要docker kafka镜像均可针对任何server.properties配置进行配置。
但是没有这样的服务器端设置可以全局影响每个副本的每个分区，以使其消耗更长的时间
如果您想订购，则可以使用一个主题，一个分区，或者将使用者线程与max.poll.records=1互锁，并在另一个使用者运行时暂停一个使用者(这很可能会很慢地运行)

have a local kafka broker

您不需要Docker，尤其是在使用Spring的EmbeddedKafka测试时