pykafka

pykafka copied to clipboard

Memory grows unbounded for producer

11

**PyKafka version**: 2.8.0 ebbc5c7 **Kafka version**: 0.8.2 **rdkafka version**: 0.11.6 I have this issue where memory grows unbounded in my container application, and the issue seems specifically tied to pykafka...

LasseGravesen

Question about dealing with broker restart

5

When a broker restarts (e.g. kafka's host system restarts), pykafka producer `produce` will fail with `NoBrokersAvailableError: Unable to connect to a broker to fetch metadata. See logs.` forever. This happens...

carsonip

why controller must present in cluster ?

2

hi all: I got a key error exception when using pykafka KeyError: 'Controller ID 200 not present in cluster' and I read the cluster.py https://github.com/Parsely/pykafka/blob/master/pykafka/cluster.py  I don't know why...

yorkhellen

logging when log doesn't exists :bug in old release

4

Noticed the following exception: `Exception ignored in: Traceback (most recent call last): File "G:\VENVIRONMENT\granular\lib\site-packages\pykafka\handlers.py", line 164, in __del__ File "G:\VENVIRONMENT\granular\lib\site-packages\pykafka\handlers.py", line 189, in stop File "C:\Python36\lib\logging\__init__.py", line 1306, in info...

vijuSR

Zookeeper topic and consumer names with b literal

4

I think a problem that I am facing relates to these two issues: https://github.com/Parsely/pykafka/issues/567 https://github.com/Parsely/pykafka/pull/569 Specifically, my problem is that Zookeeper is saving the b literal inside the string of...

Atheuz

Cluster class does not support IPv6 raw address/port

1

# Environment **PyKafka version**: 2.8.0 **Kafka version**: 2.0.0 # Procedure ``` >>> from pykafka import KafkaClient >>> >>> X_HOST_IPADDR='2406:da14:555:b701:247f:9587:88a4:f6d3' >>> client = KafkaClient(hosts=f'[{X_HOST_IPADDR}]:9090,[{X_HOST_IPADDR}]:9091,[{X_HOST_IPADDR}]:9092') Traceback (most recent call last): File "",...

takaomag

If you initialize a `KafkaClient` without a port specifier in the `hosts` kwarg (eg `KafkaClient(hosts="myhost.com")`), you get a cryptic "list index out of range error". In these cases, `KafkaClient` should...

emmettbutler

emmettbutler

The "push to PyPI" step described [here](https://github.com/Parsely/pykafka/blob/master/CONTRIBUTING.rst#release-process) should be automated. Whenever a commit is made to master whose name indicates that it should be a new version, the Travis build...

emmettbutler

python pip install

1

python version:2.7.5 can not pip install pykafka==2.8.0.dev3

yjpu