[
https://issues.apache.org/jira/browse/KAFKA-15207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744300#comment-17744300
]
Justine Olshan commented on KAFKA-15207:
----------------------------------------
It's a bit tricky to know when we are receiving a newer client request here
since the api is indirect. I suppose we could add a field to the api that
specifies what the client version was, but that would require a bump to the api.
Is there something I'm missing that would work better?
> ProducerIdManager#generateProducerId() should return different error code for
> newer clients
> -------------------------------------------------------------------------------------------
>
> Key: KAFKA-15207
> URL: https://issues.apache.org/jira/browse/KAFKA-15207
> Project: Kafka
> Issue Type: Task
> Reporter: Jeff Kim
> Priority: Major
>
> [https://github.com/apache/kafka/pull/13267] made changes to
> ProducerIdManager that does not block request handler threads while waiting
> for a new producer id block. Instead of blocking, we return
> COORDINATOR_LOAD_IN_PROGRESS.
>
> We return this rather than REQUEST_TIMED_OUT since older clients treat the
> error as fatal when it should be retriable like COORDINATOR_LOAD_IN_PROGRESS.
>
> For newer clients, we should return an error that is more aligned with what
> the client experiences.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
