Flink CDC 是一个将关系型数据库中的数据实时地传输到数据流处理引擎中的工具。master_thread_id 是 Flink CDC 中的一个线程 ID,可以用于标识和监控线程。如果你想限制 master_thread_id 的值,你需要手动配置 Flink CDC 的配置文件,并将其设置为所需的值。
在 Flink CDC 的配置文件中,你可以使用一个类似于以下格式的参数来限制 master_thread_id 的值:
spring:
cloud:
stream:
bindings:
input:
group: $
destination: your-sink-binder
properties:
worker.thread-count: 1
properties:
worker.thread-count: 2
kafka:
binder:
configuration:
领取专属 10元无门槛券
手把手带您无忧上云