pykafka
pykafka copied to clipboard
Parsely
Apache Kafka client for Python; high-level & low-level consumer/producer, with great performance.
Below is my code : Problem : Producer not writing the last two messages to the Topic. ``` `import os import asyncio import websockets from pykafka import KafkaClient from websockets.extensions...
**PyKafka Version** 2.8.0 on Linux **librdkafka Version** librdkafka1-1.1.0_confluent5.3.1-1.el7.x86_64 on Linux **Kafka Version** 2.12-2.3.0 on Windows or Linux Using `topic.get_simple_consumer(use_rdkafka=True)` results in the following error: pykafka.exceptions.RdKafkaException: Configuration property "queued.max.messages.kbytes" value 102400000...
**PyKafka version**: 2.8.0 **Kafka version**: kafka_2.12-2.2.0.jar Message has LogAppendTime on kafka server but after consuming it by pykafka simpleconsumer message timestamp = 0 **Output from kafka-console-consumer** > kafka:~$ ~/kafka/bin/kafka-console-consumer.sh --bootstrap-server...
pykafka version: 2.8.0 ``` from pykafka import KafkaClient import logging logging.basicConfig(level=logging.DEBUG, format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s', datefmt='%a, %d %b %Y %H:%M:%S', ) def connect_kafka(): client = KafkaClient(hosts="127.0.0.1:9092", broker_version="2.1.0") topic_name='test_topic' topic =...
The latest release on PyPI is from November. Any chance of releasing a new stable version?
Thanks for contributing to PyKafka. You can provide useful information that will make root cause analysis easier and get your issue fixed more quickly. First, please check the list of...
**PyKafka version**: 2.8.0 **Kafka version**: 0.11.1 ```python In [8]: lz4.__version__ Out[8]: '0.10.1' In [9]: compression.encode_lz4(memoryview(bytearray(b""))) --------------------------------------------------------------------------- TypeError Traceback (most recent call last) in ----> 1 compression.encode_lz4(memoryview(bytearray(b""))) TypeError: argument 1 must...
TLDR: is there a recommended way to use pykafka in a web app to produce messages? I need to produce some messages as part of a web application and I...
