开发者社区> 问答> 正文

canal 哪个参数可以指定kafka副本数量

canal 哪个参数可以指定kafka副本数量

如下 : canal.mq.servers =10.121.18.13:9092,10.121.18.14:9092,10.121.18.15:9092 canal.mq.retries = 0 canal.mq.batchSize = 16384 canal.mq.maxRequestSize = 1048576 canal.mq.lingerMs = 1 canal.mq.bufferMemory = 33554432 canal.mq.canalBatchSize = 50 canal.mq.canalGetTimeout = 100 canal.mq.flatMessage = true canal.mq.compressionType = none canal.mq.acks = 1

原提问者GitHub用户Bruce2jiang

展开
收起
云上静思 2023-05-04 13:01:57 84 0
2 条回答
写回答
取消 提交回答
  • 目前没有指定kafka副本这参数

    原回答者GitHub用户agapple

    2023-05-05 10:38:45
    赞同 展开评论 打赏
  • 随心分享,欢迎友善交流讨论:)

    在 Canal 中,可以通过 canal.mq.properties 参数来设置 Kafka Producer 的属性,从而实现对 Kafka 副本数量等高级属性的配置。具体来说,可以在 canal.mq.properties 参数中指定 acks、retries、batch.size、linger.ms 等参数,来影响 Kafka Producer 的行为。

    其中,acks 参数用于指定 broker 中成功写入消息的副本数,retries 参数用于指定消息发送失败时的重试次数,batch.size 参数用于设置 Producer 发送批次大小,linger.ms 参数用于设置 Producer 在等待可用数据之前的等待时间,以及 buffer.memory 参数用于设置 Producer 发送数据使用的缓冲区大小。需要注意的是,Kafka 副本数量并不是 Kafka Producer 的参数,而是由 Kafka 集群自身的配置决定的,可以通过 Kafka 的配置文件来设置。

    因此,如果需要设置 Kafka 副本数量,可以修改 Kafka 集群的配置文件,并重启 Kafka 集群来使配置生效。如果需要对 Canal 的 Kafka Producer 进行高级配置,可以使用 canal.mq.properties 参数来设置 Producer 的属性。

    2023-05-04 17:59:10
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
消息队列kafka介绍 立即下载