Hi, this is a question about error recovery. We use Openwhisk actions to process messages from Kafka with this package. Thanks! Sometimes, we have errors in our actions, or we'd like to re-process the same message later.
Is there any way to configure the package to process all existing messages in a topic, rather than just new incoming messages? It's not convenient for us to re-produce the messages into the topic using Kafka.
Hi, this is a question about error recovery. We use Openwhisk actions to process messages from Kafka with this package. Thanks! Sometimes, we have errors in our actions, or we'd like to re-process the same message later.
Is there any way to configure the package to process all existing messages in a topic, rather than just new incoming messages? It's not convenient for us to re-produce the messages into the topic using Kafka.