Open mihaitodor opened 1 day ago
redpanda_migrator_offsets
kafka_offset_metadata
TODO:
One quick way to test this is via the following config. Note how I overwrite kafka_offset_metadata to foobar in a mapping processor.
foobar
mapping
input: redpanda_migrator_bundle: redpanda_migrator: seed_brokers: [ "localhost:9092" ] topics: - '^[^_]' # Skip internal topics which start with `_` regexp_topics: true consumer_group: migrator_bundle start_from_oldest: true replication_factor_override: true replication_factor: -1 schema_registry: url: http://localhost:8081 include_deleted: true subject_filter: "" output: processors: - switch: - check: metadata("input_label") == "redpanda_migrator_offsets" processors: - mapping: | meta kafka_offset_metadata = "foobar" redpanda_migrator_bundle: redpanda_migrator: seed_brokers: [ "localhost:9093" ] max_in_flight: 1 replication_factor_override: true replication_factor: -1 schema_registry: url: http://localhost:8082
redpanda_migrator_offsets
input.kafka_offset_metadata
added to theredpanda_migrator_offsets
output.TODO:
One quick way to test this is via the following config. Note how I overwrite
kafka_offset_metadata
tofoobar
in amapping
processor.