Kafka使用过程中的一些最佳实践

组内最近一年都在使用Kafka做消息中间件做数据的流式处理,总结一下使用过程的经验教训 1.一些参数值的设定,主要是保证数据的不丢失 block.on.buffer.full = true 开启buffer缓存   acks = all retries = MAX_VALUE 生产者Producer端想kafka发送数据,要想数据不丢失,应该设置以上两个配置   max.in.flight.req
相关文章
相关标签/搜索