Kafka

阅读(60) 标签: kafka,

Ø  kafka_close()

关闭consumer连接

Ø  kafka_commit()

提交当前consumer offset的位置

Ø  kafka_open()

连接kafka server服务器

Ø  kafka_poll()

获取consumer消息记录, 返回序表

Ø  kafka_send()

producer发送消息