如何在本地Kafka复制品上模拟滞后？

bxjv4tth 于 2023-03-17 发布在 Apache

关注(0)|答案(1)|浏览(186)

我正在做一些“混沌”工程，并有Kafka运行与3经纪人本地。我阅读从一个副本，并希望测试会发生什么事时，副本离开ISR。
有什么办法可以“强迫”这种情况发生吗？因为所有的东西都是本地的，我不能“关掉wifi”或者做类似的事情。

1条答案

您可以使用trickle来限制某个代理的带宽。

trickle -s -d [download rate in KB/s] -u [upload rate in KB/s] <process of your broker>

trickle是基于这个过程完成的，我还没有测试它，但是也许最好在Kafka代理启动JVM的地方调用它，比如kafka-run-class.sh

# Which java to use
if [ -z "$JAVA_HOME" ]; then
  JAVA="trickle -s -d 10 -u 5 java"
else
  JAVA="trickle -s -d 10 -u 5 $JAVA_HOME/bin/java"
fi