State Store might migrated to another instance

2021-12-13 Thread Thomas Hein
tartingProperties.hasApplicationReachedExceptionLimit()){ LOGGER.error("After [{}] State Store retries. System is shut down", numberOfTries); System.exit(kafkaStateStoreCannotBeInitializedThusRestartExitCode); } } In 50% of the cases the state store reading throws and

State Store might migrated to another instance

2021-12-13 Thread Thomas Hein
ngProperties.hasApplicationReachedExceptionLimit()){ LOGGER.error("After [{}] State Store retries. System is shut down", numberOfTries); System.exit(kafkaStateStoreCannotBeInitializedThusRestartExitCode); } } In 50% of the cases the state store reading throws and Inval