[GitHub] [kafka] CalvinConfluent commented on pull request #13323: KAFKA-14617 Add ReplicaState to FetchRequest.

2023-03-09 Thread via GitHub


CalvinConfluent commented on PR #13323:
URL: https://github.com/apache/kafka/pull/13323#issuecomment-1462489865

   @dajac Done.


-- 
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



[GitHub] [kafka] CalvinConfluent commented on pull request #13323: KAFKA-14617 Add ReplicaState to FetchRequest.

2023-03-07 Thread via GitHub


CalvinConfluent commented on PR #13323:
URL: https://github.com/apache/kafka/pull/13323#issuecomment-1459027103

   Changing the old ReplicaId field default value to -1. In this way, we can 
easily extract the replicaId from the FetchRequest without knowing the API 
version. Simple and minimal work.


-- 
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



[GitHub] [kafka] CalvinConfluent commented on pull request #13323: KAFKA-14617; Add ReplicaState to FetchRequest.

2023-03-02 Thread via GitHub


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