在下面这段代码中,kafka.api.OffsetRequest.CurrentVersion() 是什么,它的意义是什么?从可用的文档中我不清楚。在什么情况下,需要不同的版本 id?
OffsetRequest request = new OffsetRequest(requestInfo,
kafka.api.OffsetRequest.CurrentVersion(), consumer.clientId());
在下面这段代码中,kafka.api.OffsetRequest.CurrentVersion() 是什么,它的意义是什么?从可用的文档中我不清楚。在什么情况下,需要不同的版本 id?
OffsetRequest request = new OffsetRequest(requestInfo,
kafka.api.OffsetRequest.CurrentVersion(), consumer.clientId());