用于管理Kafka连接器的Python客户端。
项目描述
kafkaconnect
使用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时跳过包含NaN和Infinity值的字段的修复。
重新组织开发者和用户指南。
在用户指南中添加有关如何本地运行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的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | 133b2335dc70ccf5749a29ed102adc6ee8d7cd11d5252d49434ea250991bdf82 |
|
MD5 | 3f2754ff7050f588ac143950285231fb |
|
BLAKE2b-256 | 8d1f2ef326db1cac380b630d0c46ccd8a8b4db59fa9fc735a00c5dad0db0d611 |
kafkaconnect-1.3.1-py3-none-any.whl的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | ff8d7c2230cdef73a26ba2e5b33aa6ff0cae66ce53665ef4d04cafafa706164c |
|
MD5 | f447f8c9ef2df3134853018910c4f6e5 |
|
BLAKE2b-256 | 5494a8b13edf525d4df06fa43f23ebf52ff47ac84b8374f763b047b981458a10 |