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:
us...@infra.apache.org
