次のコードでは、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());