[GitHub] [kafka] chia7712 commented on a change in pull request #8913: KAFKA-10191 fix flaky StreamsOptimizedTest - call KafkaStreams#cleanU…

[GitBox <gi...@apache.org>]

chia7712 commented on a change in pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#discussion_r444373556



##########
File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java
##########
@@ -303,7 +303,8 @@ public void computeTaskLags(final UUID uuid, final Map<TaskId, Long> allTaskEndO
     public long lagFor(final TaskId task) {
         final Long totalLag = taskLagTotals.get(task);
         if (totalLag == null) {
-            throw new IllegalStateException("Tried to lookup lag for unknown task " + task);
+            throw new IllegalStateException("Tried to lookup lag for unknown task: " + task
+                + " (This exception may be caused by that you don't call KafkaStreams#cleanUp when topology optimization is enabled)");

Review comment:
       you are right. I will revert it.




----------------------------------------------------------------
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org