philipnee commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1007181238
##########
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##########
@@ -618,7 +618,8 @@ private TransactionManager
configureTransactionState(ProducerConfig config,
* @throws org.apache.kafka.common.errors.UnsupportedVersionException
fatal error indicating the broker
* does not support transactions (i.e. if its version is lower
than 0.11.0.0)
* @throws org.apache.kafka.common.errors.AuthorizationException fatal
error indicating that the configured
- * transactional.id is not authorized. See the exception for more
details
+ * transactional.id is not authorized, or the idempotent producer
id is unavailable. See the exception for
Review Comment:
One could get Authorization issue upon requesting for a producerId, not
necessarily caused by an unavailable broker. Yes, maybe remove the word "fatal"
thanks!
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
