kafka-node

Kafka-node

Kafka-node 是 Apache Kafka 0.9 及更高版本的 Node.js 客户端。

目录

• 功能特性
• 安装 Kafka
• API
  • KafkaClient
  • Producer
  • HighLevelProducer
  • ProducerStream
  • Consumer
  • ConsumerStream
  • ConsumerGroup
  • ConsumerGroupStream
  • Offset
  • Admin
• 故障排除 / 常见问题
  • HighLevelProducer 使用 KeyedPartitioner 在首次发送时出错
  • 如何调试问题？
  • 对于新消费者，如何从分区中的最新消息开始消费？
  • ConsumerGroup 未在所有分区上消费
  • 如何限制消息速率 / 控制消息处理的并发度
  • 如何生产和消费二进制数据？
  • 这些 node-gyp 和 snappy 错误是什么？
  • 如何配置日志输出？
  • 错误：不是消息集。魔术字节为 2
• 运行测试
• 许可证 - "MIT"

功能特性

• 消费者
• 生产者与高级生产者
• 节点流生产者（Kafka 0.9+）
• 节点流消费者（ConsumerGroupStream Kafka 0.9+）
• 管理主题偏移量
• 与代理的 SSL 连接（Kafka 0.9+）
• SASL/PLAIN 认证（Kafka 0.10+）
• 由 Kafka 协调器管理的消费者组（Kafka 0.9+）
• 直接连接到代理（Kafka 0.9+）
• 管理 API
  • 列出组
  • 描述组
  • 创建主题

安装 Kafka

按照 Kafka 维基上的说明构建 Kafka，并启动一个测试代理使其运行起来。