Skip to content
This repository has been archived by the owner on Mar 24, 2021. It is now read-only.

Issues: Parsely/pykafka

62 Open 493 Closed
62 Open 493 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Issues list

how to ensure message not missing
#1035 opened Mar 23, 2021 by zuiwanting
the pykafka consumer is too low,
#1033 opened Feb 26, 2021 by auqf
Getting import _rd_kafka error in all docker images while trying to connect to kafka via pykafka
#1032 opened Feb 9, 2021 by naggappan
[Bug?] Exception AttributeError: "'NoneType' object has no attribute 'info'" in <bound method Producer.__del__ of <pykafka.producer.Producer at 0x118635ad0>> ignored
#1024 opened Dec 16, 2020 by ittqqzz
Producer only takes bytes, please make change to the README to reflect this
#1021 opened Dec 11, 2020 by gravityshouldbenaut
Suggest to document Partitioner Behavior in more details in Producer
#1009 opened Jul 3, 2020 by Shadowsong27
check group or all groups LAG
#1005 opened May 29, 2020 by malfonso0
pykafka producer deadlock on nosetests' integration tests
#1004 opened May 18, 2020 by hoathenguyen85
simpleconsumer.consume return type different
#1002 opened May 9, 2020 by lambgong
Error codes are out of date
#1001 opened May 7, 2020 by spenczar
Last two messages are not written to the Topic
#994 opened Feb 13, 2020 by ijbo
message consumed by pykafka simpleconsumer has timestamp value 0
#990 opened Jan 16, 2020 by ipavlyshyn
It will cause continuous continue when offset in message > next_offset
#989 opened Jan 3, 2020 by yulezheng
Does current pykafka version support all the features of kafka broker 1.1.1? Any updates regarding new version of pykafka
#987 opened Dec 17, 2019 by umeshkacha
LZ4 Compression fails with lz4 version 0.10.1
#985 opened Dec 12, 2019 by ghop02
data of my topic in kafka is so big,when i get a consumer,i cost so much time and memoery
#984 opened Dec 10, 2019 by SuperLight-007
1
advice needed: producer under gunicorn never sends messages
#983 opened Dec 4, 2019 by twillis
1
consumer.reset_offsets is not working as expected when using datatime.datetime
#976 opened Nov 5, 2019 by wkelongws
PyKafka installs a tests module into site-packages
#969 opened Sep 19, 2019 by mkmoisen
Consuming messages from a simple consumer
#968 opened Sep 18, 2019 by reutshal
use_rdkafka=True pykafka.exceptions.RdKafkaException: Configuration property "queued.max.messages.kbytes" value 102400000 is outside allowed range 1..2097151
#966 opened Sep 15, 2019 by mkmoisen
4
SimpleConsumer.consume raises 'NoneType' object has no attribute 'value' while deserializer is used.
#965 opened Sep 10, 2019 by kamilglod
OffsetFetchResponseV2 can result in offsets being lost
#958 opened Aug 15, 2019 by bobgrigoryan
Create two consumers bundled under the same group to get the same data！ hazy question
#957 opened Jul 24, 2019 by stone0018
2
Support for headers
#945 opened May 13, 2019 by rolisz
1
ProTip! Follow long discussions with comments:>50.