Advanced Settings

The Advanced Settings step is shown only for MirrorMaker 2 and Replicator jobs. Cluster Link and Orbit include their advanced settings within the Core Configuration step instead.

These settings provide fine-grained control over replication behavior. They are optional and should be adjusted only when the defaults do not meet your performance, security, or compatibility requirements.

MirrorMaker 2

MirrorMaker 2 exposes seven categories of advanced configuration.

Sync and Timing

Controls the frequency of synchronization operations and feature toggles.

Field	Description
Emit Checkpoints Interval	How often checkpoint records are emitted for offset translation.
Refresh Topics Interval	How often the connector checks for new or removed topics on the source.
Sync Topic ACLs Enabled	Toggle to synchronize topic ACLs from source to destination.
Sync Topic Configs Enabled	Toggle to synchronize topic configurations.
Emit Heartbeats Enabled	Toggle to emit heartbeat records for liveness monitoring.
Emit Checkpoints Enabled	Toggle to emit checkpoint records.
Refresh Groups Interval	How often consumer group membership is refreshed.
Sync Group Offsets Enabled	Toggle to synchronize consumer group offsets.
Sync Group Offsets Interval	How frequently group offsets are synchronized.

Consumer and Producer

Tuning parameters for the internal consumer and producer.

Consumer Settings:

Field	Description
Fetch Max Bytes	Maximum data returned per fetch request.
Fetch Min Bytes	Minimum data the broker should accumulate before responding to a fetch.
Max Poll Records	Maximum records returned per poll call.

Producer Settings:

Field	Description
Batch Size	Maximum size of a batch of records sent to the broker.
Linger ms	Time the producer waits to batch additional records before sending.
Compression Type	Compression algorithm applied to record batches (none, gzip, snappy, lz4, zstd).
Buffer Memory	Total memory available to the producer for buffering.
Acks	Number of acknowledgments required from brokers (0, 1, or all).
Retries	Number of times the producer retries a failed send.

Converters

Configure serialization and deserialization classes for keys and values.

Field	Description
Key Converter Class	Fully qualified class name for key deserialization/serialization.
Value Converter Class	Fully qualified class name for value deserialization/serialization.
Value Converter Decimal Format	Controls how decimal values are serialized (for example, BASE64 or NUMERIC).

Storage and Admin

Internal topic replication factors and admin client configuration.

Field	Description
Config Storage Replication Factor	Replication factor for the connector configuration storage topic.
Status Storage Replication Factor	Replication factor for the connector status storage topic.
Offset Storage Replication Factor	Replication factor for the connector offset storage topic.
Admin Bootstrap Servers	Bootstrap servers for the admin client.
Admin Timeout ms	Timeout for admin client operations.
Admin Retries	Number of retries for admin client operations.

Source Admin

Security configuration for the admin client that communicates with the source cluster.

Field	Description
Security Protocol	Protocol used to communicate with the source cluster admin API.
SSL Truststore Location	Path to the truststore file.
SSL Truststore Password	Password for the truststore.
SSL Keystore Location	Path to the keystore file.
SSL Keystore Password	Password for the keystore.
SASL Mechanism	SASL mechanism (PLAIN, SCRAM-SHA-256, SCRAM-SHA-512).
SASL Username	Username for SASL authentication.
SASL Password	Password for SASL authentication.

Target Admin

Security configuration for the admin client that communicates with the destination cluster.

Field	Description
Bootstrap Servers	Bootstrap servers for the target admin client.
Security Protocol	Protocol used to communicate with the destination cluster admin API.
SASL Mechanism	SASL mechanism for authentication.
SASL Username	Username for SASL authentication.
SASL Password	Password for SASL authentication.

Security Overrides

Override SASL and timeout settings for specific MirrorMaker 2 components.

Field	Description
Admin Override SASL Mechanism	Override the SASL mechanism for admin operations.
Admin Override SASL Username	Override the SASL username for admin operations.
Admin Override SASL Password	Override the SASL password for admin operations.
Producer Override SASL Mechanism	Override the SASL mechanism for producer operations.
Producer Override SASL Username	Override the SASL username for producer operations.
Producer Override SASL Password	Override the SASL password for producer operations.
Timeout Configs	Additional timeout overrides for specific components.

Cluster Linking

Cluster Linking uses default parameters optimized for most deployments. No additional advanced settings are exposed in the wizard. If you need to customize Cluster Linking behavior beyond the core configuration, refer to the Confluent Platform documentation for link-level property overrides.

Replicator

Consumer Settings:

Field	Description
Fetch Min Bytes	Minimum data the broker should accumulate before responding to a fetch request.
Fetch Max Bytes	Maximum data returned per fetch request.
Max Partition Fetch Bytes	Maximum data returned per partition per fetch request.
Max Poll Records	Maximum records returned per poll call.

Data Converters:

Field	Description
Key Converter	Converter class for record keys.
Value Converter	Converter class for record values.
Header Converter	Converter class for record headers.

Advanced:

Field	Description
Offset Translation	When enabled, consumer offsets are translated between source and destination.
Consumer Timestamps Interceptor	When enabled, timestamps from the source consumer are preserved during replication.

Caution

The Consumer Timestamps Interceptor is supported only for Java-based Kafka clients. Non-Java consumers will not benefit from timestamp preservation.

WarpStream Orbit

Field	Default	Description
Cluster Fetch Concurrency	2	Number of concurrent fetch operations the Orbit agent performs against the source cluster.
Fetch Max Bytes	100 MB	Maximum total bytes fetched per request across all partitions.
Fetch Max Partition Bytes	50 MB	Maximum bytes fetched per partition per request.

Caution

Orbit supports replicating all consumer groups or none, and all cluster configuration or none. Selective replication of individual consumer groups or configuration properties is not available.