CalvinConfluent commented on PR #13323: URL: https://github.com/apache/kafka/pull/13323#issuecomment-1452256725
@dajac I think the major question is how can the KafkaRaftClient can correctly consume the FetchRequest. The current PR makes quite some efforts to get the FetchRequest apiVersion and then parse the FetchRequest. If this way is too much trouble, I can think of another one: 1. Change the FetchRequest old ReplicaId default value to -1. 2. Then when the KafkaRaftClient receives the request, it can tell the ReplicaId by comparing the value of the old ReplicaId field and the new one(it has default value -1). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
