issues
search
wbarnha
/
kafka-python-ng
Fork for Python client for Apache Kafka
https://wbarnha.github.io/kafka-python-ng/
Apache License 2.0
67
stars
8
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Flush before close
#149
wbarnha
opened
6 months ago
2
Implemented the return type of the send function;
#148
wbarnha
closed
5 months ago
1
Support AWS_MSK_IAM authentication
#147
wbarnha
closed
6 months ago
1
Support custom SASL mechanisms
#146
wbarnha
closed
6 months ago
3
Support Describe log dirs
#145
wbarnha
closed
6 months ago
0
Fix base class of DescribeClientQuotasResponse_v0
#144
wbarnha
closed
6 months ago
0
fix: add chain_future to send method
#143
wbarnha
opened
6 months ago
0
Fix crc32c's __main__ for Python 3
#142
wbarnha
closed
6 months ago
0
Feat: FNV1a 32-Bit Partitioner
#141
wbarnha
opened
6 months ago
0
Dynamic FindCoordinator selection
#140
wbarnha
opened
6 months ago
0
Log connection errors at ERROR level
#139
wbarnha
closed
6 months ago
0
Add zstd support on legacy record and ensure no variable is referred before definition
#138
wbarnha
closed
6 months ago
0
KIP-345 Static membership implementation
#137
wbarnha
closed
6 months ago
0
feat AdminClient: support delete_records
#136
wbarnha
opened
6 months ago
0
Do not return control batch records
#135
wbarnha
opened
6 months ago
2
client_async: Allow throwing an exception upon socket error during wakeup
#134
wbarnha
closed
6 months ago
8
Strip trailing dot off hostname used for SSL validation.
#133
wbarnha
closed
6 months ago
0
Add connection_timeout_ms and reset the timeout counter more often
#132
wbarnha
closed
6 months ago
0
Update license_file to license_files
#131
wbarnha
closed
6 months ago
0
Update some RST documentation syntax
#130
wbarnha
closed
6 months ago
0
Update some RST documentation syntax
#129
wbarnha
closed
6 months ago
0
Add Kombu integration
#128
wbarnha
opened
6 months ago
0
KAFKA-3162: Add producer and consumer interceptors
#127
wbarnha
opened
6 months ago
0
Twisted interface
#126
wbarnha
opened
6 months ago
1
kafka-python should package test module / fixtures
#125
wbarnha
opened
6 months ago
0
KAFKA-3177: consumer hangs when assigned to partition that doesn't exist
#124
wbarnha
opened
6 months ago
0
Producer thread crashes if client hits fd limit
#123
wbarnha
opened
6 months ago
0
UnrecognizedBrokerVersion: Current client is 1.3.5, Latest client is 1.4.2
#122
wbarnha
opened
6 months ago
0
KafkaConsumer polls forever when the single broker is unreachable in case of manual partition assignments
#121
wbarnha
opened
6 months ago
0
KafkaConsumer does not revoke deleted partitions when using a ConsumerRebalanceListener
#120
wbarnha
opened
6 months ago
0
SSLWantReadError: The operation did not complete (read)
#119
wbarnha
opened
6 months ago
0
Using non monotonic functions to calculate elapsed time
#118
wbarnha
opened
6 months ago
0
NotEnoughReplicasError and NotEnoughReplicasAfterAppendError should be retriable.
#117
wbarnha
opened
6 months ago
0
Should pickling be re-enabled?
#116
wbarnha
opened
6 months ago
0
Rename `GroupCoordinatorRequest` to `FindCoordinatorRequest`
#115
wbarnha
opened
6 months ago
0
Add tests for KafkaAdminClient
#114
wbarnha
opened
6 months ago
0
UnsupportedSaslMechanismError raised client-side w/o checking if the broker raises it
#113
wbarnha
opened
6 months ago
0
The serialization layer is unexpectedly processed before the producer's partitioning logic
#112
wbarnha
opened
6 months ago
0
Kafka linux server power off restart ,consumer can't get message.
#111
wbarnha
opened
6 months ago
0
Is there any minimal limit for consumer_timeout_ms?
#110
wbarnha
opened
6 months ago
0
support READ_COMMITTED isolation_level
#109
wbarnha
opened
6 months ago
0
delivery_timeout_ms for KafkaProducer (KIP-91)
#108
wbarnha
opened
6 months ago
0
Make the `kafka` PyPI namespace point to the `kafka-python` namespace
#107
wbarnha
opened
6 months ago
0
kafka producer run in multi processing
#106
wbarnha
opened
6 months ago
0
Request timeout (%s) must be larger than session timeout (%s) [1.4.5]
#105
wbarnha
opened
6 months ago
0
Add support for `zstd` compression
#104
wbarnha
opened
6 months ago
1
UnrecognizedBrokerVersion raised by SSL connections
#103
wbarnha
opened
6 months ago
0
KafkaConsumer.pause() always raises `partitions must be TopicPartition namedtuples`
#102
wbarnha
opened
6 months ago
0
Consumer is missing some messages
#101
wbarnha
opened
6 months ago
0
How to log the Kafka producer/consumer erros into the logfile
#100
wbarnha
opened
6 months ago
0
Previous
Next