Parameters in the destination Kafka instance|V3.4.0|OceanBase Migration Service| docs|Distributed Database

Parameters in the destination Kafka instance

Last Updated：2023-06-25 03:32:32 Updated

Parameter	Type	Required	Default value	Description
batch.size	Integer	No	131072	The batch size.
buffer.memory	Long	No	536870912	The buffer memory.
json.serializer	String	No	DefaultJsonSerializer	The JSON serializer that serializes data to the Kafka instance. Valid values: `DefaultJsonSerializer`, `CanalJsonSerializer`, and `ShareplexJsonSerializer`. For more information, see the message format document.
kafka.servers	String	Yes	None	The Kafka service.
kafka.topic	String	Yes	None	The Kafka topic.
kafka.version	String	Yes	None	The version of the Kafka service, which can be 0.9 or 2.0.
linger.ms	Long	No	0	The time to wait before sending a batch. The value range is 0 to 2^63, in milliseconds.
max.request.size	Integer	No	1 G	The maximum size of requested data. The value range is 0 to 2^31, in bytes.
need.schema	Boolean	No	false	Specifies whether to use a schema when JSON is the default format.
partition	Integer	No	0	The partition name of the Kafka instance.
partition.mode	String	No	hash	The partitioning mode, which can be `one_partition` or `hash`. The value `one_partition` indicates that data is to be delivered to a single partition. It must be used with the partition parameter. The value `hash` indicates that data is to be delivered based on the data value defined by the sharding column.
sasl.jaas.conf.location	String	No	None	The location that stores the Java Authentication and Authorization Service (JAAS) configuration used for identity authentication during access to the Kafka service.
sasl.kerberos.conf.location	String	No	None	The location that stores the Kerberos configuration used for accessing the Kerberos server, which is also known as the key distribution center (KDC).
sasl.kerberos.keytab.location	String	No	None	The location that stores the Kerberos key table used for accessing the Kafka service.
sasl.kerberos.principal	String	No	None	The Kerberos principal used for accessing the Kafka service.
sasl.mechanism	String	No	None	The Simple Authentication and Security Layer (SASL) mechanism used for client connections. Generic Security Standard Application Programming Interface (GSSAPI) is the default mechanism.
sasl.password	String	No	None	The password of the account for accessing the Kafka service.
sasl.username	String	No	None	The username of the account for accessing the Kafka service.
security.protocol	String	No	PLAINTEXT	The security protocol used for accessing the Kafka service.
shard.fields	String	No	None	The sharding columns.
ssl.truststore.location	String	No	None	The location of the truststore.

Enterprise Edition

Community Edition

Parameters in the destination Kafka instance