Reusing the K2K configuration
The K2K Offset Mapping application uses the same YAML configuration format as the standard K2K pipeline. Its configuration extends most of the base K2K Config definitions while omitting others that are not applicable. Any valid K2K pipeline configuration can be used as a starting point for the Offset Mapping application.
In practice, this means an existing K2K configuration file can serve as a base. Only the additional fields specific to offset mapping need to be provided on top of the existing configuration to enable the feature.
name
✅
✅
features.autoCreateControlTopics
✅
✅
features.applyMappingsGuards
➖
✅
license.*
✅
✅
errorHandling.onMultipleTargetCommittedOffsets
➖
✅
errorHandling.onActiveConsumerGroupCommit
➖
✅
source.kafka.common
✅
✅
source.kafka.admin
✅
✅
target.kafka.common
✅
✅
target.kafka.producer
✅
✅
target.kafka.admin
✅
✅
target.kafka.consumer
✅
✅
metrics.prefix.targetConsumer
➖
✅
metrics.prefix.targetProducer
➖
✅
metrics.prefix.offsetMappingApp
➖
✅
Last updated
Was this helpful?

