跳转到主要内容

用于管理Kafka连接器的Python客户端。

项目描述

kafkaconnect

GitHub Actions Docker Hub repository

使用Kafka Connect API管理的连接器的Python客户端。

有关更多信息,请参阅文档

变更日志

1.3.1 (2023-07-03)

  • 向InfluxDB Sink连接器添加了–remove-prefix选项以重命名测量

1.2.0 (2023-06-12)

  • 添加了对Strimzi Kafka 0.35.1和Kafka 3.4.0的支持

1.1.0 (2023-05-28)

  • 向InfluxDB Sink连接器添加了对标签的支持

  • 添加了对Strimzi Kafka 0.34.0和Kafka 3.3.1的支持

1.0.2 (2023-01-13)

  • 添加了对Strimzi Kafka 0.32.0和Kafka 3.3.1的支持。

1.0.0 (2022-07-09)

  • 添加了对Strimzi Kafka 0.29.0和Kafka 3.1.1的支持。

  • 使用支持微秒时间戳的特殊版本的InfluxDB Sink连接器插件构建Strimzi Kafka镜像。

  • 使用Kafka Connect Avro Converter插件构建Strimzi Kafka镜像。

  • 添加了TopicNamesSet类

  • 向Kafka代理添加了SASL身份验证

0.9.3 (2021-10-29)

  • 重构S3 Sink连接器,现在它期望一个配置文件,该文件在Helm图表中进行了模板化。

  • 更新了文档。

0.9.1 (2021-06-09)

  • 添加了对配置多个InfluxDB Sink连接器的支持。

  • 添加了有关如何重置InfluxDB Sink连接器消费者组偏移量的用户指南文档。

  • 使用新的InfluxDB Sink连接器版本更新了cp-kafka-connect镜像。有关详细信息,请参阅#737

0.9.0 (2021-05-03)

  • 添加了create mirrormaker2命令

  • 添加了create jdbc-sink命令

  • 更新了依赖项

0.8.3 (2021-03-04)

  • 添加上传命令

  • 初始支持MirrorMaker 2和Confluent JDBC Sink连接器

  • 更新了依赖项

0.8.2 (2021-01-25)

  • 更新cp-kafka-connect镜像,使用新的InfluxDB Sink连接器版本。此版本将influxdb-java依赖项从版本2.9提升到2.21。特别是2.16版本引入了对写入InfluxDB时跳过包含NaNInfinity值的字段的修复。

  • 重新组织开发者和用户指南。

  • 在用户指南中添加有关如何本地运行InfluxDB Sink连接器的文档。

  • 更新了依赖项

0.8.1 (2020-10-18)

  • 修复阻止从环境读取InfluxDB密码的bug。

  • 使用Confluent Platform 5.5.2更新cp-kafka-connect镜像。

  • 更新了依赖项

0.8.0 (2020-08-05)

  • 为应用程序和连接器配置使用数据类。

  • 类似于插件的组织方式,要支持新的连接器,请添加一个cli和一个配置文件。

  • 添加对Amazon S3 Sink连接器的支持。

0.7.2 (2020-03-31)

  • 添加对InfluxDB Sink连接器的支持。

  • 添加到InfluxDB Sink连接器中选择使用的时间戳字段的–timestamp选项。

  • 修复Header Converter类配置设置。

  • 修复tasks.max配置设置名称。

  • 添加连接器name配置设置以支持相同类的多个连接器。

  • 正确处理空主题列表。

MIT许可证

版权所有2020年天文学研究大学协会(AURA)

特此授予任何获得本软件及其相关文档文件(“软件”)副本的任何人(“人”)免费使用软件的权利,不受任何限制,包括但不限于使用、复制、修改、合并、发布、分发、再许可和/或销售软件副本的权利,并允许将软件提供给软件的任何人这样做,前提是遵守以下条件

上述版权声明和本许可声明应包含在软件的所有副本或主要部分中。

软件按“原样”提供,不提供任何形式的保证,明示或暗示,包括但不限于适销性、针对特定目的的适用性和非侵权性保证。在任何情况下,作者或版权所有者均不对任何索赔、损害或其他责任承担责任,无论其性质如何,无论基于合同、侵权或其他原因,源于、产生于或与软件或软件的使用或其他交易有关。

项目详情


下载文件

下载适合您平台文件。如果您不确定选择哪个,请了解有关安装包的更多信息。

源分布

kafkaconnect-1.3.1.tar.gz (85.3 kB 查看哈希值)

上传时间:

构建分布

kafkaconnect-1.3.1-py3-none-any.whl (19.6 kB 查看哈希值)

上传时间: Python 3

由以下支持