五折优惠 所有套餐限时优惠,起价 $2.48/mo
Apache Kafka

Apache Kafka

Apache Kafka 是分布式事件流处理平台。支持 PB 级实时数据管道,已在 LinkedIn、Netflix、Uber 及 80% 的《财富》100 强企业中投入使用。持久化 Topic 日志,通过分区实现并行处理,并为高负载消息场景提供精确一次(exactly-once)语义保障。

版本

最新

操作系统

Ubuntu Server 24.04 LTS

最小 RAM

2 GB

IP 类型

IPV4,IPV6

重要文件与目录

  • Kafka 主安装目录: /opt/kafka
  • Kafka Broker 配置文件: /opt/kafka/config/server.properties
  • Kafka 日志目录(Broker 日志及已保留事件): /opt/kafka/logs
  • Kafka 可执行文件及 CLI 工具(kafka-topics.sh, kafka-console-producer.sh等等): /opt/kafka/bin
  • 用于管理 Kafka 的 Systemd 服务单元: /etc/systemd/system/kafka.service

Kafka 服务

sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka

创建主题

/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

查看 Topic 详情:

/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

生产事件(消息)

/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

每行输入一条事件。

按下 Ctrl+C 退出

消费事件

/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

按下 Ctrl+C 停止阅读。

多个客户端可以对同一批事件进行多次消费。

日志和故障排除

  • Kafka 日志: /opt/kafka/logs
  • Systemd 日志 sudo journalctl -u kafka -f
  • 确保端口 9092 (经纪商)及 9093 (controller)已开放。

更多数据库工具

相关应用

立即部署 Apache Kafka。 从 $2.48/月 起