cdc使用sasl同步kafka，出现大量Describe所有topic的问题

neilshen · 2023 年1 月 6 日 09:10

使用了。

没有配置。

相关代码下面的链接中，欢迎提 PR 贡献解决方案～

pingcap/tiflow/blob/857e7cfbe74620deb1a46a1f4cdfe383d4977fd1/cdc/sink/mq/producer/kafka/config.go#L336


      
          // DeriveTopicConfig derive a `topicConfig` from the `Config`
          func (c *Config) DeriveTopicConfig() *AutoCreateTopicConfig {
          	return &AutoCreateTopicConfig{
          		AutoCreate:        c.AutoCreate,
          		PartitionNum:      c.PartitionNum,
          		ReplicationFactor: c.ReplicationFactor,
          	}
          }
          
          // NewSaramaConfig return the default config and set the according version and metrics
          func NewSaramaConfig(ctx context.Context, c *Config) (*sarama.Config, error) {
          	config := sarama.NewConfig()
          
          	version, err := sarama.ParseKafkaVersion(c.Version)
          	if err != nil {
          		return nil, cerror.WrapError(cerror.ErrKafkaInvalidVersion, err)
          	}
          	var role string
          	if contextutil.IsOwnerFromCtx(ctx) {
          		role = "owner"
          	} else {