Error handling
In order for the consumer offset mapping functionality to work, both of the following requirements must be met:
K2K must be configured to publish offset mappings.
The
k2k-offset-mappingapplication must be configured and deployed.
Without both components active, consumer group offsets on the target cluster will not be translated.
The K2K Offset Mapping application may encounter situations during operation that are symptomatic of a configuration or environmental problem. Its error handling configuration provides control over how the application should respond to these specific conditions.
fail: Stops the application immediately upon error detection, preventing any further offset synchronization. This is the safest option and is recommended for most deployments.ignore: Logs the error and allows the application to continue operating. This should be used with caution, as ignoring persistent errors can lead to incorrect offset translations or obscure serious underlying problems.
Duplicate offset mappings
Defines the behavior when a single record has two associated offset mappings. This can occur when two K2K instances with different Records routing configurations the same source topics between the same source and target cluster pair.
Active consumer on target
Defines the behavior when an offset commit to the target cluster fails because a consumer application is actively registered in the target consumer group.
errorHandling:
onMultipleTargetCommittedOffsets: "fail"
onActiveConsumerGroupCommit: "fail"Last updated
Was this helpful?

