亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

調用 GetMetadata 時禁用自動主題創建

調用 GetMetadata 時禁用自動主題創建

Go
LEATH 2023-06-01 17:17:13
我正在為我的 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 回答

?
HUWWW

TA貢獻1874條經驗 獲得超12個贊

要禁用自動創建主題,您應該更新您的代理配置以將auto.create.topics.enableas設置為false.?


查看完整回答
反對 回復 2023-06-01
  • 1 回答
  • 0 關注
  • 133 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號