全部标签

Tag

Kafka

3 篇文章
Docker compose Kafka ip映射

在某些开发和测试场景下,我们希望通过 Docker Compose 快速部署一个 Kafka 环境,并且能够从 Docker 外部(例如宿主机或其他机器)访问它。这时,正确配置 Kafka 的 IP 映射就显得尤为重要。 dockercompose.yml 示例 以下是一个部署单节点 Kafka 和 Zookeeper 的 dockercompose.yml

736 字 | 2 分钟
如何解决kafka Response Heartbeat The group is rebalancing, so a rejoin is needed导致重复调用eachMessage函数

其实这个报错非常恶心人,如果是入库等程序一般不会遇到,但是如果是请求网页的进程,很容易就遇到了,然后就会心跳超时,之后就会重启消费者,重新执行eachMessage函数,但是之前的eachMessage函数依然在执行,会导致eachMessage越来越多然后卡死。 这里是两篇遇到这个问题的文章,第一个解决的方法是 HOW TO RESOLVE THIS IS

763 字 | 2 分钟