Resetting an Airy Kafka streaming app
How to reset an Airy component.
The Airy Core
components are Kafka streaming apps which consume and produce to Kafka. Each of them has its own consumer group that can be reset, to re-read all the events and messages from the beginning or from a certain offset.
#
Consumer group informationInformation about the Kafka consumer groups used by Airy Core
can be printed out with the following command:
To retrieve information about the particular consumer group run:
#
Reset the Kafka streaming appOnce you have the information about the consumer group, you can proceed with reset the kafka-streaming app.
First scale down the particular component:
Then reset the Kafka streaming app:
Then scale the app back up:
#
ExampleFor example, to reset the api-communication
streaming app, run the following commands: