因此可以看到源码中,如果消息收集器中的消息收集结果为空或者新的消息批次已经创建好,进行sender唤醒,执行wakeup操作的,唤醒Sender线程的。...timestamp, serializedKey,
serializedValue, headers, interceptCallback, remainingWaitMs);
//如果消息收集器中的消息收集结果为空或者新的消息批次已经创建好...RecordAppendResult appendResult = tryAppend(timestamp, key, value, headers, callback, dq);
//如果追加的消息不为空...transactionManager;
Sender线程
处理将生产请求发送到Kafka集群的后台线程。...//已知broker支持的当前请求API版本
private final ApiVersions apiVersions;
/* all the state related to transactions