ableegoldman commented on a change in pull request #11604:
URL: https://github.com/apache/kafka/pull/11604#discussion_r770929975
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java
##########
@@ -221,9 +222,14 @@ public RemoveNamedTopologyResult removeNamedTopology(final
String topologyToRemo
.getMessage()
.equals("Deleting offsets of a topic is
forbidden while the consumer group is actively subscribed to it.")) {
ex.printStackTrace();
+ } else if (ex.getCause() != null &&
+ ex.getCause() instanceof
GroupIdNotFoundException) {
+ log.debug("The offsets have been reset and it
retied again, no longer retrying.");
Review comment:
```suggestion
log.debug("The offsets have been reset by
another client or the group has been deleted, no need to retry further.");
```
--
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]
