lianetm commented on code in PR #16449:
URL: https://github.com/apache/kafka/pull/16449#discussion_r1674077031
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##########
@@ -1501,11 +1501,11 @@ public void unsubscribe() {
private void resetGroupMetadata() {
groupMetadata.updateAndGet(
- oldGroupMetadataOptional -> oldGroupMetadataOptional
- .map(oldGroupMetadata -> initializeConsumerGroupMetadata(
- oldGroupMetadata.groupId(),
- oldGroupMetadata.groupInstanceId()
- ))
+ oldGroupMetadataOptional -> oldGroupMetadataOptional
+ .map(oldGroupMetadata ->
initializeConsumerGroupMetadata(
+ oldGroupMetadata.groupId(),
+ oldGroupMetadata.groupInstanceId()
+ ))
Review Comment:
format is off here right? (I guess it's because you had it inside an `if` at
some point, but was then removed). I expect we should end up with the
`resetGroupMetadata` unchanged in this PR
--
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
