mjsax commented on PR #20570: URL: https://github.com/apache/kafka/pull/20570#issuecomment-3368612944
> looks like I missed an important moment that we can use sensors in init. so simply separating the init is not going to work I think, you "just" need to update `TopologyTestDriver` to also call the new `assignThread` method: https://github.com/apache/kafka/blob/trunk/streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java#L514 As we split the initialization into two calls, `task.initializeIfNeeded()` is not sufficient -- but if we actually don't change the `Task` interface, and don't touch `StreamTask` but only `StandbyTask` as proposed above, the issue should go away by itself. -- 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]
