本(ben)文(wen)主(zhu)要(yao)介(jie)紹在(zai)命令行模(mo)式下不(bu)使用SASL證書連接Kafka實例的操作，其中(zhong)包(bao)含內網(wang)訪(fang)問(wen)和公網(wang)訪(fang)問(wen)兩(liang)種(zhong)連接場景。
在不使用SASL證書的(de)場(chang)景下，通過(guo)內網(wang)訪(fang)問(wen)(wen)和通過(guo)公網(wang)訪(fang)問(wen)(wen)，僅涉及連接(jie)IP和端口不一致，其他操作(zuo)步驟是一樣的(de)。內網(wang)訪(fang)問(wen)(wen)的(de)連接(jie)端口為(wei)9092，公網(wang)訪(fang)問(wen)(wen)的(de)連接(jie)端口為(wei)9094。
文中僅(jin)介紹公網訪(fang)問的(de)連接示例，如果使用內網訪(fang)問時，替換相(xiang)應的(de)連接地(di)址即(ji)可。
說明Kafka實例的每個代理允許客戶端單IP連接的個數默認為1000個，如果超過了，會出現連接失敗問題。您可以通過修改配置參數來修改單IP的連接數。
前提條件
1.已配置正(zheng)確的安全組，安全組規則請(qing)參(can)考準備環境中(zhong) 表安全組規則。
2.已獲取連接(jie)Kafka實(shi)例的(de)地(di)址。
- 如果是使用內網通過同一個VPC訪問，實例端口為9092，實例連接地址獲取如下圖。
圖使用(yong)內網通過(guo)同一個VPC訪問Kafka實(shi)例的連接地址（實(shi)例未開啟SASL）
- 如果是公網訪問，實例端口為9094，實例連接地址獲取如下圖。
圖 公(gong)網訪問(wen)Kafka實(shi)例的連接地址（實(shi)例未開啟(qi)SASL）
3.如果Kafka實例未開(kai)啟自(zi)動創建Topic功能，獲(huo)取Topic名稱。
在實例的Topic管理頁簽中獲取（可選）步驟三：創建Topic中創建(jian)的(de)Topic名稱(cheng)。
圖 查看Topic名稱
4.已購買ECS，并完成JDK安裝、環境變量配置以及Kafka開源客戶端下載，具體操作請參考準備環境。
生產消息
進(jin)入Kafka客(ke)戶端文件的“/bin”目錄下(xia)，執行(xing)(xing)如下(xia)命令進(jin)行(xing)(xing)生產(chan)消息(xi)：
./kafka-console-producer.sh --broker-list ?{連接地址} --topic 連接地址??topic?{Topic名稱}
參數說明如下：
- 連接地址：從前提條件中獲取的連接地址。
- Topic名稱：Kafka實例下創建的Topic名稱。
示例如下，“10.3.196.45:9094,10.78.42.127:9094,10.4.49.103:9094”為獲(huo)取(qu)的Kafka實例公網連接地址(zhi)。
執行(xing)完命令(ling)后，輸入(ru)需要生(sheng)產的消息內容，按“Enter”發送消息到Kafka實例，輸入(ru)的每一行(xing)內容都將作為(wei)一條消息發送到Kafka實例。
[root@ecs-kafka bin]# ./kafka-console-producer.sh --broker-list 10.3.196.45:9094,10.78.42.127:9094,10.4.49.103:9094 ?--topic topic-demoHello
DMS
Kafka!
^C[root@ecs-kafka bin]#
如需停止生產使用Ctrl+C命令退出。
消費消息
執行如下命令(ling)進行消費(fei)消息：
./kafka-console-consumer.sh --bootstrap-server ?{連接地址} --topic 連接地址??topic?{Topic名稱} --group ${消費組名稱} --from-beginning
參數說明如下：
- 連接地址：從前提條件中獲取的連接地址。
- Topic名稱：Kafka實例下創建的Topic名稱。
- 消費組名稱：根據您的業務需求，設定消費組名稱。 如果已經在配置文件中指定了消費組名稱，請確保命令行中的消費組名稱與配置文件中的相同，否則可能消費失敗。 消費組名稱開頭包含特殊字符，例如下劃線“_”、#號“#”時，監控數據無法展示。
示例如下：
[root@ecs-kafka bin]# ?./kafka-console-consumer.sh --bootstrap-server 10.3.196.45:9094,10.78.42.127:9094,10.4.49.103:9094 --topic topic-demo --group order-test --from-beginning
Kafka!
DMS
Hello
^CProcessed a total of 3 messages
[root@ecs-kafka bin]#
如需(xu)停(ting)止(zhi)消費使用Ctrl+C命(ming)令退出。
后續步驟
您可(ke)以通過(guo)設置監(jian)控指標的告警規格，當實例、節點、隊列等(deng)有異常時(shi)，可(ke)以及時(shi)接收異常信息。
