Types-confluent-kafka

Latest version: v1.3.1

Safety actively analyzes 723158 Python packages for vulnerabilities to keep your Python projects secure.

Scan your dependencies

Page 1 of 3

1.3.1

[1.3.1](https://github.com/benbenbang/types-confluent-kafka/compare/1.3.0...1.3.1) (2024-12-22)

:hotsprings: CI, Workflows & Configs

* **workflow:** tmp bring back publish job ([227](https://github.com/benbenbang/types-confluent-kafka/issues/227)) ([5baaad7](https://github.com/benbenbang/types-confluent-kafka/commit/5baaad73c31fc806219d9f50fb0308e1db93f217))

:beetle: Bug Fixes

* **cimpl:** update Message.headers arg-type ([212](https://github.com/benbenbang/types-confluent-kafka/issues/212)) ([6ff3084](https://github.com/benbenbang/types-confluent-kafka/commit/6ff3084bfbd18212b49d61607a3f1ed25d24303c))

1.3.0

[1.3.0](https://github.com/benbenbang/types-confluent-kafka/compare/1.2.2...1.3.0) (2024-12-12)

:gift: Features

* annotations for 2.5.0 compatibility ([203](https://github.com/benbenbang/types-confluent-kafka/issues/203)) ([c880da6](https://github.com/benbenbang/types-confluent-kafka/commit/c880da6579807622d02f95e680d7a0647ecd5fa0))

:hotsprings: CI, Workflows & Configs

* **workflow:** diable ruff F821, F822 ([211](https://github.com/benbenbang/types-confluent-kafka/issues/211)) ([686aec4](https://github.com/benbenbang/types-confluent-kafka/commit/686aec49a2989e08bef49d40410f2635bbfeaa21)), closes [/#diff-50c86b7ed8ac2cf95bd48334961bf0530cdc77b5a56f852c5c61b89d735fd711R75-R77](https://github.com/benbenbang///issues/diff-50c86b7ed8ac2cf95bd48334961bf0530cdc77b5a56f852c5c61b89d735fd711R75-R77)
* **workflow:** revamp github workflows for new release process ([210](https://github.com/benbenbang/types-confluent-kafka/issues/210)) ([6cc365a](https://github.com/benbenbang/types-confluent-kafka/commit/6cc365a93d033069d854e90969e8df2be5b7f886)), closes [/#diff-7829468e86c1cc5d5133195b5cb48e1ff6c75e3e9203777f6b2e379d9e4882b3R15-R69](https://github.com/benbenbang///issues/diff-7829468e86c1cc5d5133195b5cb48e1ff6c75e3e9203777f6b2e379d9e4882b3R15-R69) [/#diff-b71166ed0f585913318ed46933ff9b12901e211de3ac88c40de03f0a944c0ae0R1-R128](https://github.com/benbenbang///issues/diff-b71166ed0f585913318ed46933ff9b12901e211de3ac88c40de03f0a944c0ae0R1-R128) [/#diff-a0a6e4ee69a6cc56b171c351e636c911c000b6e5e878c6e4d01f28b5983571adR1-R55](https://github.com/benbenbang///issues/diff-a0a6e4ee69a6cc56b171c351e636c911c000b6e5e878c6e4d01f28b5983571adR1-R55) [/#diff-392d32aead49dc01d6f1f97762613932c065f2dbfc6028466e14cc05e8bf4128R1-R32](https://github.com/benbenbang///issues/diff-392d32aead49dc01d6f1f97762613932c065f2dbfc6028466e14cc05e8bf4128R1-R32) [/#diff-18813c86948efc57e661623d7ba48ff94325c9b5421ec9177f724922dd553a35L1-R17](https://github.com/benbenbang///issues/diff-18813c86948efc57e661623d7ba48ff94325c9b5421ec9177f724922dd553a35L1-R17) [/#diff-2f754321d62f08ba8392b9b168b83e24ea2852bb5d815d63e767f6c3d23c6ac5R1-R5](https://github.com/benbenbang///issues/diff-2f754321d62f08ba8392b9b168b83e24ea2852bb5d815d63e767f6c3d23c6ac5R1-R5) [/#diff-add758cac95c0fbd5cdbd0982745afdd667e9ee831a44c6c0fb32774ab34dd8aR1-R45](https://github.com/benbenbang///issues/diff-add758cac95c0fbd5cdbd0982745afdd667e9ee831a44c6c0fb32774ab34dd8aR1-R45) [#209](https://github.com/benbenbang/types-confluent-kafka/issues/209)
* **workflow:** swap events order ([218](https://github.com/benbenbang/types-confluent-kafka/issues/218)) ([2a7ff4b](https://github.com/benbenbang/types-confluent-kafka/commit/2a7ff4b74a7702a8bd5e0410b38279cfea5ab076))
* **workflow:** tmp revert old release workflows ([225](https://github.com/benbenbang/types-confluent-kafka/issues/225)) ([5a5e7d2](https://github.com/benbenbang/types-confluent-kafka/commit/5a5e7d200fe2bee9dc0b87f6ab78dfbd6cb403dc))
* **workflow:** update trigger event ([217](https://github.com/benbenbang/types-confluent-kafka/issues/217)) ([e83dfc9](https://github.com/benbenbang/types-confluent-kafka/commit/e83dfc9d1f144ded16a70146141f96895dfbf6ba)), closes [/#diff-b71166ed0f585913318ed46933ff9b12901e211de3ac88c40de03f0a944c0ae0R7-R9](https://github.com/benbenbang///issues/diff-b71166ed0f585913318ed46933ff9b12901e211de3ac88c40de03f0a944c0ae0R7-R9)

:beetle: Bug Fixes

* add missing bool to AdminClient create_partitions method ([196](https://github.com/benbenbang/types-confluent-kafka/issues/196)) ([7824ef8](https://github.com/benbenbang/types-confluent-kafka/commit/7824ef8c4dafd3627cd5a2a54ffb88a583e40453))
* **admin:** update return value with only None in the Futures ([205](https://github.com/benbenbang/types-confluent-kafka/issues/205)) ([26ee521](https://github.com/benbenbang/types-confluent-kafka/commit/26ee5216094731a652ef444bb0362c47f9393118))
* **lint:** apply ruff format ([214](https://github.com/benbenbang/types-confluent-kafka/issues/214)) ([6449606](https://github.com/benbenbang/types-confluent-kafka/commit/6449606c1919ccdb062c9c76a9ce558f6a81da27))
* make Consumer.poll timeout default to None ([221](https://github.com/benbenbang/types-confluent-kafka/issues/221)) ([d79fde9](https://github.com/benbenbang/types-confluent-kafka/commit/d79fde9196f61d689d8a18dbd479696c88315f1e))
* rename parameter in Consumer.list_topics ([220](https://github.com/benbenbang/types-confluent-kafka/issues/220)) ([0ee388a](https://github.com/benbenbang/types-confluent-kafka/commit/0ee388a35bb912d40b5f36618f1ca3d57f9827a5)), closes [/github.com/confluentinc/confluent-kafka-python/blob/0e5706b71adbfea5a178f1bec3587ec29bb8aff9/src/confluent_kafka/src/Metadata.c#L416-L427](https://github.com/benbenbang//github.com/confluentinc/confluent-kafka-python/blob/0e5706b71adbfea5a178f1bec3587ec29bb8aff9/src/confluent_kafka/src/Metadata.c/issues/L416-L427)
* use concurrent.future.Future instead of asyncio.Future ([198](https://github.com/benbenbang/types-confluent-kafka/issues/198)) ([f4491a5](https://github.com/benbenbang/types-confluent-kafka/commit/f4491a5adf475ef087487484a256d10facebe80b))

1.2.2

[1.2.2](https://github.com/benbenbang/types-confluent-kafka/compare/1.2.1...1.2.2) (2024-07-07)

:beetle: Bug Fixes

* **cimpl:** typo in cimpl stub ([194](https://github.com/benbenbang/types-confluent-kafka/issues/194)) ([b213d8f](https://github.com/benbenbang/types-confluent-kafka/commit/b213d8f9b2ee44fc2319ffdff666cb9c1d6cf305))

1.2.1

[1.2.1](https://github.com/benbenbang/types-confluent-kafka/compare/1.2.0...1.2.1) (2024-05-02)


:hammer_and_pick: Enhancement & Maintenance

* **_model:** drop classvar in _model module ([171](https://github.com/benbenbang/types-confluent-kafka/issues/171)) ([75ece8c](https://github.com/benbenbang/types-confluent-kafka/commit/75ece8c24e7155ba0e9d76059a1b794475ca7d76))
* **admin:** drop classvar in admin module ([173](https://github.com/benbenbang/types-confluent-kafka/issues/173)) ([5871c83](https://github.com/benbenbang/types-confluent-kafka/commit/5871c83b295cc6789655dd0c74d1ae63d62e4a64))
* **avro:** drop classvar in avro module ([180](https://github.com/benbenbang/types-confluent-kafka/issues/180)) ([305d743](https://github.com/benbenbang/types-confluent-kafka/commit/305d743f612c8439b940b9d392fd107d08eb6383))
* drop classvar in schema registry module ([182](https://github.com/benbenbang/types-confluent-kafka/issues/182)) ([43362c5](https://github.com/benbenbang/types-confluent-kafka/commit/43362c5628f80fb76c465e6e1695ee5a91cd9adc))
* **error:** drop classvar in error.py ([175](https://github.com/benbenbang/types-confluent-kafka/issues/175)) ([f3fa6b8](https://github.com/benbenbang/types-confluent-kafka/commit/f3fa6b8fd5dd48528c5f77accbcac915fc5c6508))


:hotsprings: CI, Workflows & Configs

* update gitignore ([165](https://github.com/benbenbang/types-confluent-kafka/issues/165)) ([cff4f1b](https://github.com/benbenbang/types-confluent-kafka/commit/cff4f1babce68574cc7384b2b74af2d31d6b3bf9))
* update runner macos version to match its arch ([187](https://github.com/benbenbang/types-confluent-kafka/issues/187)) ([421758f](https://github.com/benbenbang/types-confluent-kafka/commit/421758f572a8b177115173f59fe39c29a1dc5ad1))


:beetle: Bug Fixes

* avro & json (de)serializer return types ([178](https://github.com/benbenbang/types-confluent-kafka/issues/178)) ([95a7bf1](https://github.com/benbenbang/types-confluent-kafka/commit/95a7bf140117e53f8ac12ef8cc00b4ce0622a88e))
* Serialization annotations to match docs ([185](https://github.com/benbenbang/types-confluent-kafka/issues/185)) ([ceb3059](https://github.com/benbenbang/types-confluent-kafka/commit/ceb30590155892032f672ab59865116c3b5ca847))
* **serializer:** update json serializer signatures ([169](https://github.com/benbenbang/types-confluent-kafka/issues/169)) ([ce28fd2](https://github.com/benbenbang/types-confluent-kafka/commit/ce28fd211a428bd0fe35859f288a2b1635461cf4))

1.2.0

[1.2.0](https://github.com/benbenbang/types-confluent-kafka/compare/1.1.0...1.2.0) (2024-02-08)


:gift: Features

* add logger keyword argument to consumer and producer ([163](https://github.com/benbenbang/types-confluent-kafka/issues/163)) ([5fe69e6](https://github.com/benbenbang/types-confluent-kafka/commit/5fe69e683ed87cec871960adbab7fe05c695cf06))

1.1.0

[1.1.0](https://github.com/benbenbang/types-confluent-kafka/compare/1.0.1...1.1.0) (2023-12-03)


:gift: Features

* more concrete type annotations ([159](https://github.com/benbenbang/types-confluent-kafka/issues/159)) ([1946043](https://github.com/benbenbang/types-confluent-kafka/commit/1946043426f60e8725f921feab93f630f8a9a6fa)), closes [#158](https://github.com/benbenbang/types-confluent-kafka/issues/158)


:beetle: Bug Fixes

* **build:** update confluent kafka python client to fix librkafka ([161](https://github.com/benbenbang/types-confluent-kafka/issues/161)) ([4f35648](https://github.com/benbenbang/types-confluent-kafka/commit/4f35648a8d8f530aa62b17277ca1fb507f587f07))

Page 1 of 3

© 2025 Safety CLI Cybersecurity Inc. All Rights Reserved.