应用与数据集成平台 ROMA CONNECT-Kafka:配置参数

时间：2024-01-15 20:44:40

表1 发送消息
参数	说明
主题	填写需要监听的topic。
Partition	消息将被写入的分区。
Key	消息Key值。
Message	消息内容。
Acks	发送确认参数。 all -1 0 1
KeySerializer	键的序列化方式，默认为org.apache.kafka.common.serialization.StringSerializer。
ValueSerializer	值的序列化方式，默认为org.apache.kafka.common.serialization.StringSerializer。
BufferMemorySize	producer可以用来缓存数据的内存大小，默认为33554432。
Retries	重试次数。