在 flume 与 kafka 对接的数据流中出现的问题java.nio.BufferUnderflowExceptionflume 日志中报错信息如下:ERROR [kafka-producer-network-thread | producer-1] (org.apache.kafka.clients.producer.internals.Sender.run:130)- U...

数据丢失的原因Kafka 消息发送分同步 (sync)、异步 (async) 两种方式，默认使用同步方式，可通过 producer.type 属性进行配置；通过 request.required.acks 属性进行配置：值可设为 0, 1, -1(all)-1 和 all 等同0 代表：不等待 broker 的 ack，这一操作提供了一个最低的延迟，broker 一接收到还没有...