文档文档

Flux

kafka 包

kafka 包提供了用于使用 Apache Kafka 的工具。导入 kafka 包

import "kafka"

函数

kafka

此页是否对您有帮助？

感谢您的反馈！

© 2025 InfluxData, Inc.

您在哪里运行 InfluxDB？

选择您的 InfluxDB Cloud 区域和集群 或您的 InfluxDB OSS URL，我们将为您定制代码示例。识别您的 InfluxDB Cloud 集群。

  • InfluxDB Cloud
  • InfluxDB OSS 或 企业版版
AWS

  • 美西（俄勒冈州）

GCP
Azure
默认
自定义

有关更多信息，请参阅 InfluxDB Cloud 区域 或 InfluxDB OSS URL。

感谢您的反馈！

请告诉我们如何做得更好

谢谢！

不用了，谢谢

InfluxDB 对 kafka 包的支持

InfluxDB Cloud

InfluxDB 开源 (OSS)

InfluxDB 1.7

InfluxDB 1.8

InfluxDB 1.11

InfluxDB 2.0

InfluxDB 2.1

InfluxDB 2.2

InfluxDB 2.3

InfluxDB 2.4

InfluxDB 2.5

InfluxDB 2.6

InfluxDB 2.7

InfluxDB Enterprise

InfluxDB Enterprise 1.7

InfluxDB Enterprise 1.8

InfluxDB Enterprise 1.9

InfluxDB Enterprise 1.10

InfluxDB Enterprise 1.11

  • 待定（可能尚未完全部署或在此版本中可用）
  • 在此 InfluxDB 版本中已弃用

有关每个 InfluxDB 版本中可用的 Flux 版本的信息，请参阅InfluxDB 中的 Flux 版本。

Flux 的未来

Flux 即将进入维护模式。您可以继续像当前一样使用它，而无需对您的代码进行任何更改。

阅读更多

现已全面上市

InfluxDB 3 Core 和 Enterprise

快速启动。更快扩展。

获取更新

InfluxDB 3 Core 是一个开源、高速、最近数据引擎，可实时收集和处理数据，并将其持久化到本地磁盘或对象存储。InfluxDB 3 Enterprise 构建在 Core 的基础上，增加了高可用性、读取副本、增强的安全性以及数据压缩功能，以实现更快的查询和优化的存储。InfluxDB 3 Enterprise 的免费层级可供非商业家庭或业余爱好者使用。

有关更多信息，请查看