aio-libs/aiokafka issues and pull requests

#1092 - Add concurrent consumption example to docs

Pull Request - State: open - Opened by Arseniy-Popov 3 days ago

#1091 - Transactional Example not working

Issue - State: open - Opened by marcosschroh 12 days ago - 1 comment

#1089 - [KIP 932] Share Groups Support

Issue - State: open - Opened by rupurt 22 days ago
Labels: enhancement

#1088 - Add round robin partitioner

Pull Request - State: open - Opened by Arseniy-Popov 23 days ago

#1087 - Support OffsetRequest_v2

Issue - State: open - Opened by y4n9squared 28 days ago
Labels: enhancement

#1086 - [QUESTION] Why is passing the loop to Consumer and Producer deprecated?

Issue - State: open - Opened by rnixx 29 days ago
Labels: question

#1085 - [QUESTION] Support for Apache Kafka 4.0

Issue - State: open - Opened by ijuma about 1 month ago - 1 comment
Labels: question

#1084 - How does partition reassignment occur instantly when on_partitions_revoked suggests committing offsets?

Issue - State: open - Opened by mdanish0320 about 1 month ago
Labels: question

#1081 - [QUESTION] extremly high Fetch Rate

Issue - State: open - Opened by mosinnik 3 months ago - 2 comments
Labels: question

#1080 - Consumer/channel does not reauthenticate based on SaslAuthenticateResponse

Issue - State: open - Opened by moh-incom 3 months ago - 1 comment

#1076 - Use SPDX license identifier

Pull Request - State: open - Opened by cdce8p 3 months ago - 1 comment

#1075 - Add stub typing for clients

Pull Request - State: open - Opened by jackgene 3 months ago - 1 comment

#1074 - Added type annotation to public classes.

Pull Request - State: open - Opened by jackgene 3 months ago

#1073 - [QUESTION] How to detect connection issues with a consumer?

Issue - State: open - Opened by anetbnd 3 months ago
Labels: question

#1072 - [QUESTION] SSL: UNEXPECTED_MESSAGE

Issue - State: closed - Opened by rvaidun 4 months ago - 1 comment
Labels: question

#1071 - Fix manual commit documentation page is misleading

Pull Request - State: closed - Opened by memew1se 4 months ago - 1 comment

#1070 - Manual commit documentation page is misleading

Issue - State: closed - Opened by memew1se 4 months ago

#1069 - Update Java Client API reference

Pull Request - State: closed - Opened by emmanuel-ferdman 4 months ago - 3 comments

#1068 - Fix incomplete documentation for AIOKafkaConsumer.offset_for_times

Pull Request - State: closed - Opened by jzvandenoever 4 months ago - 2 comments

#1067 - Consumer.offsets_for_times return type documentation is incomplete.

Issue - State: closed - Opened by jzvandenoever 4 months ago

#1065 - [QUESTION] send() vs send_and_wait()

Issue - State: closed - Opened by hakan458 4 months ago - 1 comment
Labels: question

#1063 - Update actions, fix publishing

Pull Request - State: closed - Opened by ods 4 months ago

#1062 - Fix spelling mistakes in documentation

Pull Request - State: closed - Opened by IamsahilPhadtare 4 months ago

#1061 - Add Python 3.13, remove 3.8

Pull Request - State: closed - Opened by ods 4 months ago - 1 comment

#1060 - Producers hangs while stopping in frozen datetime context

Issue - State: open - Opened by mdczaplicki 4 months ago

#1059 - [QUESTION] Long running process prevents auto-commit

Issue - State: closed - Opened by 24dlong 4 months ago - 2 comments
Labels: question

#1058 - please provide python 3.13 support

Issue - State: closed - Opened by sugadge 4 months ago - 3 comments
Labels: enhancement

#1057 - Automatic DateTime Serialization Support in aiokafka

Issue - State: closed - Opened by RebelRaider 4 months ago - 7 comments
Labels: enhancement

#1056 - Fix ClusterMetadata request_update()

Pull Request - State: closed - Opened by jackgene 4 months ago - 1 comment

#1055 - ClusterMetadata, `update_metadata(...)` always fails when following `request_update()` call

Issue - State: closed - Opened by jackgene 4 months ago - 2 comments

#1054 - [QUESTION] Getting commit errors after group rebalances

Issue - State: closed - Opened by dhillonr 4 months ago - 1 comment
Labels: question

#1053 - Made classes enum.IntEnums where appropriate.

Pull Request - State: closed - Opened by jackgene 4 months ago - 1 comment

#1052 - Changed BrokerMetadata#nodeId to str, and convert all values to str before setting

Pull Request - State: closed - Opened by jackgene 4 months ago

#1051 - Updated BrokerMetadata#nodeId type from `int` to `int | str`.

Pull Request - State: closed - Opened by jackgene 4 months ago - 4 comments

#1050 - [MINOR] structs.BrokerMetadata#nodeId incorrectly typed

Issue - State: closed - Opened by jackgene 5 months ago

#1049 - `test_read_write_serde_v2` fails (CRC do not match)

Issue - State: closed - Opened by rominf 5 months ago - 1 comment

#1047 - Bump actions/download-artifact from 2 to 4.1.7 in /.github/workflows

Pull Request - State: closed - Opened by dependabot[bot] 6 months ago - 2 comments
Labels: dependencies, github_actions

#1046 - [QUESTION] Retrying getmany batch if it fails before manual committing

Issue - State: closed - Opened by marcelolima 6 months ago
Labels: question

#1045 - Admin client: list offsets per topic/partition

Issue - State: open - Opened by noamta-gloat 6 months ago
Labels: enhancement

#1044 - fix: check writer is closing in AIOKafkaConnection.send

Pull Request - State: open - Opened by dimastbk 6 months ago - 1 comment

#1043 - Quote username in SCRAM auth

Pull Request - State: closed - Opened by ods 6 months ago - 1 comment

#1041 - [QUESTION] Is there a way to monitor the heartbeat state?

Issue - State: closed - Opened by simonzhlx 7 months ago - 1 comment
Labels: question

#1040 - [QUESTION] Is there a way to monitor the heartbeat state?

Issue - State: open - Opened by simonzhlx 7 months ago
Labels: question

#1039 - Producer.send_and_wait() hangs up forever if `sender_task` is cancelled

Issue - State: open - Opened by homm 7 months ago

#1038 - Closing of connection from server don't caught for uvloop

Issue - State: open - Opened by dimastbk 7 months ago

#1037 - Long running consumer stop receiving messages and it's state is not closed

Issue - State: open - Opened by Tinanuaa 7 months ago - 5 comments

#1036 - fix type on producer docs

Pull Request - State: closed - Opened by lgo 7 months ago

#1034 - Add readthedocs config

Pull Request - State: closed - Opened by ods 7 months ago - 1 comment

#1033 - Remove outdated information from the doc

Pull Request - State: closed - Opened by vmaurin 7 months ago - 2 comments

#1032 - lz4 compression codec not found even after installing lz4 module

Issue - State: closed - Opened by suryaprabhakark 7 months ago - 5 comments

#1031 - Losing Messages Between Producer and Consumer

Issue - State: open - Opened by hakan458 7 months ago - 6 comments

#1030 - Integrate tokenless publishing @ GHA CD workflow

Pull Request - State: closed - Opened by webknjaz 7 months ago
Labels: enhancement

#1029 - Return back mac x86_64 wheels

Pull Request - State: closed - Opened by ods 7 months ago - 1 comment

#1028 - Severe performance degradation after migrating to cramjam LZ4

Issue - State: open - Opened by y4n9squared 8 months ago - 5 comments

#1027 - A large and controversial proposal: replace protocol implementation with kio

Issue - State: open - Opened by antonagestam 8 months ago - 3 comments
Labels: enhancement

#1026 - Add type hints to message_accumulator

Pull Request - State: open - Opened by antonagestam 8 months ago

#1025 - Remove duplicate error log during rebalance

Pull Request - State: closed - Opened by y4n9squared 8 months ago

#1024 - add typing to aiokafka/cluster.py

Pull Request - State: open - Opened by dimastbk 8 months ago

#1023 - Update `aiokafka` library to support higher client versions > 3

Issue - State: open - Opened by Ben621 8 months ago - 8 comments
Labels: enhancement

#1022 - Fix building/testing wheels for mac

Pull Request - State: closed - Opened by ods 8 months ago

#1021 - add typing to aiokafka/conn.py

Pull Request - State: open - Opened by dimastbk 8 months ago - 1 comment

#1020 - Connection errors are spamming

Issue - State: open - Opened by legau 8 months ago - 1 comment

#1019 - Unclosed AIOKafkaConnection that does not cause the consumer to crash

Issue - State: open - Opened by YraganTron 8 months ago - 1 comment

#1018 - Can't Recover From NotLeaderForPartitionError

Issue - State: open - Opened by oferda4 8 months ago

#1017 - [QUESTION] idempotent producer and OutOfOrderSequenceNumber problem

Issue - State: open - Opened by funkindy 8 months ago - 1 comment
Labels: question

#1016 - Add client.rack configuration option to support consumer fetching from closest replica (KIP-392)

Issue - State: open - Opened by trentbitterman 8 months ago
Labels: enhancement

#1015 - [QUESTION] Is there support to refresh OAuth tokens automatically based on token expiration duration?

Issue - State: open - Opened by sara-han 8 months ago
Labels: question

#1014 - Added delay to retry connection

Pull Request - State: open - Opened by camcima 8 months ago

#1013 - [QUESTION] How to close connection if Kafka server isn't responding?

Issue - State: open - Opened by conradogarciaberrotaran 9 months ago
Labels: question

#1012 - Bump requests from 2.31.0 to 2.32.2

Pull Request - State: closed - Opened by dependabot[bot] 9 months ago - 2 comments
Labels: dependencies

#1011 - Pin requests version to fix CI

Pull Request - State: closed - Opened by ods 9 months ago

#1010 - [QUESTION] Restarting `AIOKafkaConsumer` after `AIOKafkaConsumer.stop()`

Issue - State: open - Opened by dom-gunstone 9 months ago - 4 comments
Labels: question

#1009 - change request metadata error to warning

Pull Request - State: closed - Opened by oferda4 9 months ago - 1 comment

#1008 - IncompatibleBrokerVersion: Kafka broker does not support the 'CreateTopicsRequest_v0' Kafka protocol.

Issue - State: open - Opened by mjunaidca 9 months ago - 4 comments

#1007 - Fix unintended cancellation of fetcher task

Pull Request - State: closed - Opened by apmorton 10 months ago - 1 comment

#1006 - add typing to aiokafka/coordinator/*

Pull Request - State: closed - Opened by dimastbk 10 months ago - 1 comment

#1005 - add typing to tests/test_protocol*

Pull Request - State: closed - Opened by dimastbk 10 months ago - 1 comment

#1004 - Unexpected error during batch delivery

Issue - State: open - Opened by KPull 10 months ago - 1 comment

#1003 - seek_to_committed does not work when committed offset is 0

Issue - State: open - Opened by t7wakim 10 months ago

#1002 - [QUESTION] How to check readiness of kafka to receive msgs from producer?

Issue - State: open - Opened by Olegt0rr 10 months ago - 1 comment
Labels: question

#1001 - add typing to aiokafka/record/*

Pull Request - State: closed - Opened by dimastbk 10 months ago - 3 comments

#1000 - Fixed CancelledError being raised from various .close() methods

Pull Request - State: open - Opened by agronholm 10 months ago

#999 - add typing to aiokafka/protocol/*

Pull Request - State: closed - Opened by dimastbk 10 months ago - 4 comments

#998 - [QUESTION] How to get old messages from topics?

Issue - State: open - Opened by solidguy7 10 months ago - 4 comments
Labels: question

#997 - refactor: add type hints to protocol

Pull Request - State: closed - Opened by odysa 11 months ago - 2 comments

#996 - Send create/delete topics request to controller

Pull Request - State: closed - Opened by ods 11 months ago - 1 comment

#995 - admin client - failure to create topics (error code 41)

Issue - State: closed - Opened by kbhatiya999 11 months ago - 3 comments

#994 - Typing in test_helpers; switch to pytest style

Pull Request - State: closed - Opened by ods 11 months ago - 1 comment

#993 - Fix typing bugs found by beartype

Pull Request - State: closed - Opened by ods 11 months ago - 5 comments

#992 - [QUESTION] Unable connect to node with id: X: [Errno 111]: Connection refused

Issue - State: open - Opened by OlehDziuba 11 months ago
Labels: question

#990 - High Incoming request sum on Azure Event Hub

Issue - State: open - Opened by jmd9019 11 months ago

#989 - Type annotations for helpers

Pull Request - State: closed - Opened by ods 11 months ago - 1 comment

#988 - Type annotations for errors

Pull Request - State: closed - Opened by ods 11 months ago - 1 comment

#987 - Drop unnecessary hack with WeakMethod

Pull Request - State: closed - Opened by ods 11 months ago - 1 comment

#986 - Update ruff to 0.3.2, apply more linting rules

Pull Request - State: closed - Opened by ods 11 months ago - 1 comment

#985 - Fix DescribeConfigsResponse_v1 config_source (dpkp/kafka-python#150)

Pull Request - State: closed - Opened by ods 12 months ago - 1 comment

#984 - Type annotations in aiokafka/codec.py

Pull Request - State: closed - Opened by ods 12 months ago - 1 comment

#983 - Consumer stopped consuming, task Fetcher._fetch_task has finished

Issue - State: closed - Opened by pavelschon 12 months ago - 8 comments

#982 - add more type hints

Pull Request - State: closed - Opened by alm0ra about 1 year ago - 2 comments
Labels: priority:low

#981 - Fix add more type hints

Pull Request - State: closed - Opened by alm0ra about 1 year ago - 1 comment

GitHub / aio-libs/aiokafka issues and pull requests