Skip to content

Activity

Showing most recent first

import re

dpkppushed 1 commit to dpkp/validate-topic-names • 0645aab…6214a99 • 
15 hours ago

Move ensure_valid_topic_name to kafka.util; use in client and producer

dpkpcreated dpkp/validate-topic-names • 0645aab • 
22 hours ago

KIP-70: Auto-commit offsets on consumer.unsubscribe()

dpkpcreated dpkp/kip-70 • ce88b6d • 
22 hours ago

Test older pythons against 4.0 broker

dpkppushed 1 commit to master • 3f3314c…cd4830a • 
yesterday

Use get_open_port for KRaft controller port

dpkppushed 1 commit to master • 301828a…3f3314c • 
yesterday

Update kafka broker compatibility docs

dpkppushed 1 commit to master • 3bd280a…301828a • 
yesterday

Deleted branch

dpkpdeleted dpkp/4.0-fixture • 
yesterday

Support KRaft / 4.0 brokers in tests (#2559)

Pull request merge
dpkppushed 1 commit to master • 4995e9b…3bd280a • 
yesterday

Add 4.0 broker to test matrix

dpkppushed 1 commit to dpkp/4.0-fixture • 07b0d30…a404033 • 
yesterday

Use cli to create topics in 4.0 for now

dpkppushed 5 commits to dpkp/4.0-fixture • b816a22…07b0d30 • 
yesterday

kafka.properties

dpkppushed 1 commit to dpkp/4.0-fixture • f609f6a…b816a22 • 
yesterday

KIP-511: Use ApiVersions v4 on initial connect w/ client_software_nam…

Pull request merge
dpkppushed 1 commit to master • e6fa9f3…4995e9b • 
yesterday

conftest whitespace

dpkpcreated dpkp/4.0-fixture • f609f6a • 
yesterday

Try ApiVersions v4 on initial connect

dpkpcreated dpkp/api-versions-v4 • b2452a5 • 
yesterday

Add python 3.13 to compatibility list

dpkppushed 1 commit to master • 9afaa41…e6fa9f3 • 
3 days ago

Deleted branch

dpkpdeleted dpkp/partitions-for-topic-empty • 
4 days ago

Return empty set from consumer.partitions_for_topic when topic not fo…

Pull request merge
dpkppushed 1 commit to master • 39f2a6d…9afaa41 • 
4 days ago

Return empty set from consumer.partitions_for_topic when topic not found

dpkpcreated dpkp/partitions-for-topic-empty • 0d6df19 • 
5 days ago

Bump version for development

dpkppushed 1 commit to master • bea9d46…39f2a6d • 
5 days ago

Patch Release 2.1.2

dpkppushed 1 commit to master • 14643ca…bea9d46 • 
5 days ago

Deleted branch

dpkpdeleted dpkp/fetcher-next-fetch-offset • 
5 days ago

simplify consumer.poll send fetches logic

Pull request merge
dpkppushed 12 commits to master • d4a6a05…14643ca • 
5 days ago

simplify consumer.poll send fetches logic

Force push
dpkpforce pushed to dpkp/fetcher-next-fetch-offset • b0b81dc…2cfbe35 • 
5 days ago

Deleted branch

dpkpdeleted dpkp/fetcher-retriable • 
5 days ago

Fix Fetcher retriable error handling (#2554)

Pull request merge
dpkppushed 1 commit to master • b406824…d4a6a05 • 
5 days ago

wip

dpkpcreated dpkp/fetcher-next-fetch-offset • b0b81dc • 
5 days ago

Fix Fetcher retriable error handling

dpkpcreated dpkp/fetcher-retriable • 237c765 • 
5 days ago

Fix consumer offset tracking on pause/resume

dpkpcreated dpkp/pause-resume-offset • 25bcdc0 • 
6 days ago

Deleted branch

dpkpdeleted dpkp/metaclass-py3 • 
6 days ago

Use six.add_metaclass for py2/py3 compatible abc (#2551)

Pull request merge
dpkppushed 1 commit to master • ca5592f…b406824 • 
6 days ago