Filebeat -> Kafka消息

Question

我正在使用Filebeat，将日志发送到Kafka。在某些情况下，filebeat日志显示以下消息：

Apr 17 20:14:10 appserver filebeat: 2018/04/18 00:14:10.378702 log.go:36: 
INFO producer/broker/[[0]] maximum request accumulated, waiting for space

我想知道，这条消息出现的原因是什么？这是一个问题吗？我必须做些什么才能防止if出现？

Answer 1

基于Filebeat使用的Kafka客户端库的this github issue，看起来Filebeat正在以高于您的Kafka代理可以接受的速度生成。你可能想要扩展Kafka (更多的分区和代理)，或者改变required_acks parameter。