Parsely/pykafka

Issues

• how to ensure message not missing

  #1035 opened 3 years ago by zuiwanting
  0

• kafka-test pykafka.exceptions.SocketDisconnectedError

  #1034 opened 3 years ago by mailtoshrb
  1

• the pykafka consumer is too low,

  #1033 opened 3 years ago by auqf
  0

• Getting import _rd_kafka error in all docker images while trying to connect to kafka via pykafka

  #1032 opened 3 years ago by naggappan
  0

• error discovering offset manager occasionally occurs when get_balanced_consumer

  #1014 opened 3 years ago by liown
  0

• Very slow when I use PyKafka with asyncio

  #1022 opened 3 years ago by littleningmeng
  0

• [Bug?] Exception AttributeError: "'NoneType' object has no attribute 'info'" in <bound method Producer.__del__ of <pykafka.producer.Producer at 0x118635ad0>> ignored

  #1024 opened 3 years ago by ittqqzz
  0

• Producer only takes bytes, please make change to the README to reflect this

  #1021 opened 4 years ago by gravityshouldbenaut
  0

• Dependabot couldn't authenticate with https://pypi.org/simple/

  #1015 opened 4 years ago by dependabot-preview
  0

• Suggest to document Partitioner Behavior in more details in Producer

  #1009 opened 4 years ago by Shadowsong27
  0

• Loosing messages when producing

  #912 opened 4 years ago by rubinatorz
  7

• check group or all groups LAG

  #1005 opened 4 years ago by malfonso0
  0

• pykafka producer deadlock on nosetests' integration tests

  #1004 opened 4 years ago by hoathenguyen85
  0

• simpleconsumer.consume return type different

  #1002 opened 4 years ago by lambgong
  0

• Error codes are out of date

  #1001 opened 4 years ago by spenczar
  0

• Last two messages are not written to the Topic

  #994 opened 4 years ago by ijbo
  0

• use_rdkafka=True pykafka.exceptions.RdKafkaException: Configuration property "queued.max.messages.kbytes" value 102400000 is outside allowed range 1..2097151

  #966 opened 5 years ago by mkmoisen
  4

• message consumed by pykafka simpleconsumer has timestamp value 0

  #990 opened 4 years ago by ipavlyshyn
  0

• It will cause continuous continue when offset in message > next_offset

  #989 opened 4 years ago by yulezheng
  0

• New release?

  #944 opened 5 years ago by rolisz
  2

• Does current pykafka version support all the features of kafka broker 1.1.1? Any updates regarding new version of pykafka

  #987 opened 4 years ago by umeshkacha
  0

• LZ4 Compression fails with lz4 version 0.10.1

  #985 opened 5 years ago by ghop02
  0

• advice needed: producer under gunicorn never sends messages

  #983 opened 5 years ago by twillis
  1

• data of my topic in kafka is so big,when i get a consumer,i cost so much time and memoery

  #984 opened 5 years ago by SuperLight-007
  1

• consumer.reset_offsets is not working as expected when using datatime.datetime

  #976 opened 5 years ago by wkelongws
  0

• Support for headers

  #945 opened 5 years ago by rolisz
  1

• Create two consumers bundled under the same group to get the same data！

  #957 opened 5 years ago by stone0311
  2

• PyKafka installs a tests module into site-packages

  #969 opened 5 years ago by mkmoisen
  0

• Consuming messages from a simple consumer

  #968 opened 5 years ago by reutshal
  0

• RdKafkaException: receive.message.max.bytes must be >= fetch.max.bytes + 512

  #960 opened 5 years ago by aguyyala-disco
  2

• SimpleConsumer.consume raises 'NoneType' object has no attribute 'value' while deserializer is used.

  #965 opened 5 years ago by kamilglod
  0

• OffsetFetchResponseV2 can result in offsets being lost

  #958 opened 5 years ago by bobgrigoryan
  0

• Proper handling of ProduceFailureError?

  #940 opened 5 years ago by rjemanuele
  1

• Auto-created topics partitions incorrect / divide by zero

  #941 opened 5 years ago by rjemanuele
  3

• why send "offset + 1" while sending (partitions, offset) to consumer.commit_offsets()

  #938 opened 5 years ago by vijuSR
  1

• why only one partition that can receives message?

  #935 opened 5 years ago by migowei0621
  0

• Error committing offsets for topic ,pykafka.exceptions.UnknownMemberId

  #933 opened 5 years ago by llicety
  0

• librdkafka dependency and setup issues

  #920 opened 5 years ago by carsonip
  6

• pykafka witth librdkafka

  #926 opened 5 years ago by ananthmeka
  2

• Bi-direct communication handle in kafka

  #930 opened 5 years ago by teguh87
  1

• ManagedBalancedConsumer compacted_topic default value

  #923 opened 5 years ago by emmettbutler
  4

• Alias Broker._connection to Broker.connection?

  #925 opened 5 years ago by dsuch
  0

• Incompatible LZ4 compression causes error in Kafka and fails the delivery

  #914 opened 5 years ago by carsonip
  7

• Does pykafka support kafka version 1.0.x

  #919 opened 5 years ago by jinsust
  1

• Documentation regarding Message

  #917 opened 5 years ago by DieterDePaepe
  1

• Starting consumer in django

  #916 opened 5 years ago by kyao-Frndz
  2

• pykafka.exceptions.UnknownTopicOrPartition after kafka topic partition reassignment

  #909 opened 5 years ago by ethicalmohit
  3

• Memory grows unbounded for producer

  #906 opened 5 years ago by LasseGravesen
  11

• Question about dealing with broker restart

  #908 opened 5 years ago by carsonip
  5

• Missing LZ4 documentation

  #902 opened 5 years ago by carsonip
  1