看下是否是kafka用户的权限问题,TiCDC通过ACL连接Kafka是有一定的权限要求的:
ACL 授权TiCDC 能够正常工作所需的最小权限集合如下:
(1)对 Topic 资源类型 的 Create 和 Write 权限。
(2)对 Cluster 资源类型的 DescribeConfigs 权限。
可以看下:TiCDC 无法接入kafka.
看下是否是kafka用户的权限问题,TiCDC通过ACL连接Kafka是有一定的权限要求的:
ACL 授权TiCDC 能够正常工作所需的最小权限集合如下:
(1)对 Topic 资源类型 的 Create 和 Write 权限。
(2)对 Cluster 资源类型的 DescribeConfigs 权限。
可以看下:TiCDC 无法接入kafka.