Fix incorrect behavior of aiven_mirrormaker_replication_flow schema fields:
sync_group_offsets_enabled
sync_group_offsets_interval_seconds
emit_heartbeats_enabled
emit_backward_heartbeats_enabled
offset_syncs_topic_location
replication_policy_class
Resolves: #1632.
Why this way
The current way it works is broken. Additionally, offset_syncs_topic_location and replication_policy_class should be required, because they can't be empty, and API then converts an empty string to their default values, source and org.apache.kafka.connect.mirror.DefaultReplicationPolicy respectively.
About this change—what it does
Fix incorrect behavior of
aiven_mirrormaker_replication_flowschema fields:sync_group_offsets_enabledsync_group_offsets_interval_secondsemit_heartbeats_enabledemit_backward_heartbeats_enabledoffset_syncs_topic_locationreplication_policy_classResolves: #1632.
Why this way
The current way it works is broken. Additionally,
offset_syncs_topic_locationandreplication_policy_classshould be required, because they can't be empty, and API then converts an empty string to their default values,sourceandorg.apache.kafka.connect.mirror.DefaultReplicationPolicyrespectively.