cadonna commented on code in PR #13318:
URL: https://github.com/apache/kafka/pull/13318#discussion_r1153174856
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##########
@@ -564,14 +566,26 @@ public void start() {
// initialize the last commit as of now to prevent first commit
happens immediately
this.lastCommitMs = time.milliseconds();
+
+ log.info("StateUpdater thread started");
Review Comment:
I see. What about having the log line
```
Starting StateUpdater thread
```
here, then
```
StateUpdater thread started
```
in the beginning of method `run()` of the thread as well as
```
Shutting down StateUpdater thread
```
in `shutdown()` and
```
StateUpdater thread shut down
```
at the end of `run()` in the thread.
--
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
