Skip to content

Commit dc8de27

Browse files
committed
address comments
1 parent a2ec840 commit dc8de27

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1500,7 +1500,7 @@ private void runRebalanceCallbacksOnClose() {
15001500

15011501
int memberEpoch = groupMetadata.get().get().generationId();
15021502

1503-
final Exception error;
1503+
Exception error = null;
15041504

15051505
if (streamsRebalanceListenerInvoker != null && streamsRebalanceListenerInvoker.isPresent()) {
15061506

0 commit comments

Comments
 (0)