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