Add more logs to the test

This commit is contained in:
Aravinda Kidambi Srinivasan 2024-05-02 11:20:39 -07:00
parent da1ff05b1b
commit 78e3b27601

View file

@ -958,8 +958,8 @@ public class ShardConsumerTest {
log.info("Scheduler Thread: Invoking ShardConsumer.executeLifecycle() to invoke subscribe and" +
" complete initialization");
consumer.executeLifecycle();
// initialization should be done by now, make sure shard consumer did not
// perform shutdown processing yet.
log.info("Scheduler Thread: Done initializing the ShardConsumer");
log.info("Verifying scheduler did not perform shutdown transition during initialization");
verify(mockState, times(0)).shutdownTransition(any());
}