新版kafka的KafkaProducer调用RecordAccumulator.append第二次试着追加消息问题

坡度比2022-10-02  8

新版kafka的kafkaProducer第二次调用RecordAccumulator.append尝试追加消息问题。新版Kafka的KafkaProducer第二次调用RecordAccumulator.append尝试追加消息问题。导读:第二次尝试追加记录到RecordBatch时,为什么要提前分配空,添加不成功后再释放空,而不是第二次添加不成功后再分配空? 解决方法:
转载请注明原文地址:https://juke.outofmemory.cn/read/1869449.html

最新回复(0)