confluent-kafka-python is based on librdkafka v1.5.0, see the librdkafka release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
v1.4.2
Confluent's Python client for Apache Kafka
v1.4.2 is a maintenance release with the following fixes and enhancements:
Fix produce/consume hang after partition goes away and comes back,
such as when a topic is deleted and re-created (regression in v1.3.0).
Consumer: Reset the stored offset when partitions are un-assign()ed.
This fixes the case where a manual offset-less commit() or the auto-committer
would commit a stored offset from a previous assignment before
a new message was consumed by the application
Seed random number generator used for random broker selection.
Multiple calls to Consumer.close will not raise RunTimeError (@mkmoisen , #678)
Don't send empty credentials to SR in Authorization Header (#863)
miscellaneous test cleanup and enhancements (@nicht#843 ,#863)
confluent-kafka-python is based on librdkafka v1.4.2, see the librdkafka v1.4.2 release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
KIP-511: Report client software name and version to broker
Generic Serde API (experimental)
New AvroSerializer and AvroDeserializer implementations including configurable subject name strategies.
JSON Schema support (For Schema Registry)
Protobuf support (For Schema Registry)
confluent-kafka-python is based on librdkafka v1.4.0, see the librdkafka v1.4.0 release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
v1.6.0 is a feature release with the following features, fixes and enhancements:
Bundles librdkafka v1.6.0 which adds support for Incremental rebalancing,
Sticky producer partitioning, Transactional producer scalabilty improvements,
and much much more. See link to release notes below.
Rename asyncio.py example to avoid circular import (#945)
The Linux wheels are now built with manylinux2010 (rather than manylinux1)
since OpenSSL v1.1.1 no longer builds on CentOS 5. Older Linux distros may
thus no longer be supported, such as CentOS 5.
The in-wheel OpenSSL version has been updated to 1.1.1i.
Added Message.latency() to retrieve the per-message produce latency.
Added trove classifiers.
Consumer destructor will no longer trigger consumer_close(),
consumer.close() must now be explicitly called if the application
wants to leave the consumer group properly and commit final offsets.
Fix PY_SSIZE_T_CLEAN warning
Move confluent_kafka/ to src/ to avoid pytest/tox picking up the local dir
Added producer.purge() to purge messages in-queue/flight (@peteryin21, #548)
Added AdminClient.list_groups() API (@messense, #948)
Rename asyncio.py example to avoid circular import (#945)
confluent-kafka-python is based on librdkafka v1.6.2, see the
librdkafka release notes
for a complete list of changes, enhancements, fixes and upgrade considerations.
v1.5.2
v1.5.2 is a maintenance release with the following fixes and enhancements:
Add producer purge method with optional blocking argument (@peteryin21, #548)
Rename asyncio.py example to avoid circular import (#945)
Upgrade bundled OpenSSL to v1.1.1h (from v1.0.2u)
The Consumer destructor will no longer trigger consumer.close()
callbacks, consumer.close() must now be explicitly called to cleanly
close down the consumer and leave the group.
Fix PY_SSIZE_T_CLEAN warning in calls to produce().
Restructure source tree to avoid undesired local imports of confluent_kafka
when running pytest.
confluent-kafka-python is based on librdkafka v1.5.2, see the
librdkafka release notes
for a complete list of changes, enhancements, fixes and upgrade considerations.
Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting @dependabot rebase.
If all status checks pass Dependabot will automatically merge this pull request.
Dependabot commands and options
You can trigger Dependabot actions by commenting on this PR:
- `@dependabot rebase` will rebase this PR
- `@dependabot recreate` will recreate this PR, overwriting any edits that have been made to it
- `@dependabot merge` will merge this PR after your CI passes on it
- `@dependabot squash and merge` will squash and merge this PR after your CI passes on it
- `@dependabot cancel merge` will cancel a previously requested merge and block automerging
- `@dependabot reopen` will reopen this PR if it is closed
- `@dependabot close` will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually
- `@dependabot ignore this major version` will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself)
- `@dependabot ignore this minor version` will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself)
- `@dependabot ignore this dependency` will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself)
- `@dependabot use these labels` will set the current labels as the default for future PRs for this repo and language
- `@dependabot use these reviewers` will set the current reviewers as the default for future PRs for this repo and language
- `@dependabot use these assignees` will set the current assignees as the default for future PRs for this repo and language
- `@dependabot use this milestone` will set the current milestone as the default for future PRs for this repo and language
- `@dependabot badge me` will comment on this PR with code to add a "Dependabot enabled" badge to your readme
Additionally, you can set the following in your Dependabot [dashboard](https://app.dependabot.com):
- Update frequency (including time of day and day of week)
- Pull request limits (per update run and/or open at any time)
- Automerge options (never/patch/minor, and dev/runtime dependencies)
- Out-of-range updates (receive only lockfile updates, if desired)
- Security updates (receive only security updates, if desired)
Bumps confluent-kafka from 0.11.4 to 1.6.0.
Release notes
Sourced from confluent-kafka's releases.
... (truncated)
Changelog
Sourced from confluent-kafka's changelog.
... (truncated)
Commits
56aa46b
Changelog for v1.6.08069f26
Minor doc editsf1ace08
Bump docs copyright year32ad9f6
Merge pull request #1020 from confluentinc/tst1522e50f40
Reduce smoketest to Py 2.7 and Py 3.862731e8
Bump to librdkafka v1.6.0 actual54890e2
Merge pull request #1019 from mhowlett/lnote665b8e1
Rearrange426d53b
Added ASF notice to README3990a2f
Travis: restructure wheel buildingDependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting
@dependabot rebase
.If all status checks pass Dependabot will automatically merge this pull request.
Dependabot commands and options
You can trigger Dependabot actions by commenting on this PR: - `@dependabot rebase` will rebase this PR - `@dependabot recreate` will recreate this PR, overwriting any edits that have been made to it - `@dependabot merge` will merge this PR after your CI passes on it - `@dependabot squash and merge` will squash and merge this PR after your CI passes on it - `@dependabot cancel merge` will cancel a previously requested merge and block automerging - `@dependabot reopen` will reopen this PR if it is closed - `@dependabot close` will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually - `@dependabot ignore this major version` will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself) - `@dependabot ignore this minor version` will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself) - `@dependabot ignore this dependency` will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself) - `@dependabot use these labels` will set the current labels as the default for future PRs for this repo and language - `@dependabot use these reviewers` will set the current reviewers as the default for future PRs for this repo and language - `@dependabot use these assignees` will set the current assignees as the default for future PRs for this repo and language - `@dependabot use this milestone` will set the current milestone as the default for future PRs for this repo and language - `@dependabot badge me` will comment on this PR with code to add a "Dependabot enabled" badge to your readme Additionally, you can set the following in your Dependabot [dashboard](https://app.dependabot.com): - Update frequency (including time of day and day of week) - Pull request limits (per update run and/or open at any time) - Automerge options (never/patch/minor, and dev/runtime dependencies) - Out-of-range updates (receive only lockfile updates, if desired) - Security updates (receive only security updates, if desired)