You can only close() the Kafka Streams client and create a new one to resume (offsets are committed on close() and thus would be picked up on restart).

Closing and restarting would result in rebalancing thought, so to really pause/resume you would need to close() all instances.


There is no API to pause()/resume() similar to what the KafkaConsumer offers.


-Matthias


On 11/22/21 2:10 PM, Miguel González wrote:
Hello there

Is it possible to pause/restart a Kafka streams app? I have only found this
discussion
https://groups.google.com/g/confluent-platform/c/Nyj3eN-3ZlQ/m/lMH-bFx-AAAJ
about using map to call an external service and loop until some condition
completes

regards
- Miguel

Reply via email to