我正在為我的 Kafka 客戶端使用confluent golang 。我用來AdminClient在 kafka 集群中創建/刪除/獲取主題。這是我要初始化的代碼AdminClientadminClient, err := kafka.NewAdminClient(&kafka.ConfigMap{? ? "bootstrap.servers": 127.0.0.1:9092,})之后,我使用這個類來創建和獲取kafka集群中的所有主題。下面是創建主題的代碼:ctx, cancel := context.WithCancel(context.Background())defer cancel()results, err := adminClient.CreateTopics(? ? ctx,? ? []kafka.TopicSpecification{{? ? ? ? Topic:? ? ? ? ? ? ?topic,? ? ? ? NumPartitions:? ? ?numPartitions,? ? ? ? ReplicationFactor: replicationFactor}},? ? kafka.SetAdminOperationTimeout(TimeOut),)之后,我再次獲得主題信息:result, err := adminClient.GetMetadata(&topic, false, 1000)問題是:如果我得到一個以前不存在的主題,kafka 會自動創建該主題。這是我不想要的行為。請告訴我如何解決這個問題。
- 1 回答
- 0 關注
- 133 瀏覽
添加回答
舉報
0/150
提交
取消