pykafka

pykafka copied to clipboard

add private method __getHost for setup default port to 9092

1

i am fixed how could #870 this my version realization if it's ok i resume commits if there is remarks I'll correct

morgangt

Feature SASL SCRAM support

6

This pull request adds support for modular SASL authentication mechanisms with two mechanisms (PLAIN, SCRAM) already implemented. closes #651

swenzel

Bumps [xxhash](https://github.com/ifduyue/python-xxhash) from 1.3.0 to 2.0.0. Release notes Sourced from xxhash's releases. v2.0.0 Require xxHash version >= v0.8.0 Upgrade xxHash to v0.8.0 XXH3 hashes: xxh3_64, xxh3_128, and their oneshot functions...

dependabot-preview[bot]

**PyKafka version**: 2.8.0 I m not sure I m doing this correctly, but based on what I have read in docs and source code, to produce messages into a specific...

Shadowsong27

hi.. i would like to know if there is a way to get the lag, as in how many messages are still pending to read. per topic or for all...

malfonso0

I posted a question at https://stackoverflow.com/questions/61800654/pykafka-deadlock-on-nosetests-integration-tests. This only happens on python3.6. We are using pykafka 2.7.0 on kafka 1.0.0. When running nosetest that goes through following code: ``` def publish(self,...

hoathenguyen85

**PyKafka version**: 2.8.1-dev.2 **Kafka version**: 0.10 When i use python 2.7 simpleconsumer.consume return string type msg But when i use python 3.6 simpleconsumer.consume return bytes type msg Is that normal?...

lambgong

pykafka's list of Kafka error codes [only goes up to 30](https://github.com/Parsely/pykafka/blob/e7665bf36bfe521050fdcb017c68e92365bd89ed/pykafka/exceptions.py#L254) as of e7665bf36bfe521050fdcb017c68e92365bd89ed. Kafka v2.5.0 has [88 error codes](https://kafka.apache.org/protocol#protocol_error_codes). When an unknown error code is hit, pykafka raises a...

spenczar

Using @functools.wrap ensures that docstrings for wrapped functions are passed through the decorator correctly. Before: ``` $ pydoc pykafka.broker.Broker.create_topics Help on function wrapped in pykafka.broker.Broker: pykafka.broker.Broker.create_topics = wrapped(self, *args, **kwargs)...

spenczar

Allow for producing to topics dynamically.

17

Currently, a new producer needs to be instantiated for each topic that you want to produce to. I am working on a service that intakes messages from many producers, and...

ottomata