librdkafka庫使用

時間 2021-01-19

標籤 bootstrap 服務器 ide 字符串 kafka class require 欄目 Bootstarp 简体版

原文原文鏈接

1）底層支持重連服務器bootstrap

%3|1600150057.893|ERROR|rdkafka#consumer-1| [thrd:192.168.58.95:9092/bootstrap]: 192.168.58.95:9092/0: Connect to ipv4#192.168.58.95:9092 failed: 因爲目標計算機積極拒絕，沒法鏈接服務器

當服務器恢復正常，可以正常重連ide

2）必須指定一個groupid，能夠是任意的一串字符串ui

/* Consumer groups require a group id */
if (!group)
group = "rdkafka_consumer_example";ip

3）rd_kafka_consumer_poll會返回超時信息或者發送數據字符串

-191是超時信息
kafka

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。