memphis.py

memphis.py copied to clipboard

John-Memphis

Rdo 6 1 liner sdk examples

3

John-Memphis

Bug: Improve error description

6

### Describe the bug Hey, I was trying to produce a protobuf dict to a station without schema attached and received the following error: ``` $ python3 producer-protobuf.py memphis: Unsupported...

yanivbh1

stop consume functionality

3

I have created a stopConsume method with self parameter, refefered in the issue #139 ``` def stopConsume(self): if self.t_consume is not None: self.t_consume.cancel() self.t_consume = None ``` **__In this code...

Adarsh-jaiss

Stop consume functionality

7

We want users to make use of the consumer.consume function, will be able to stop the automatic consumption. So we need a new function consumer.stopConsume which will be responsible to...

Avitaltrifsik

Currently, to destroy a consumer, you first have to create a consumer object.: ```python print("Create consumer") consumer = await memphis.consumer(station_name=STATION, consumer_name="test-consumer-2", consumer_group="", start_consume_from_sequence=1) await consumer.destroy() ``` This can be problematic...

rnowling-memphis

Currently, producers and consumers all share a single connection to the Memphis broker. The user creates a `Memphis` object and calls `connect()` to establish a connection. When producers and consumers...

rnowling-memphis

The [current implementation](https://github.com/memphisdev/memphis.py/blob/master/memphis/producer.py#L154) for asynchronous production of messages doesn't provide an error handling mechanism. We could provide a callback function through the [`add_done_callback()`](https://docs.python.org/3/library/asyncio-task.html#asyncio.Task.add_done_callback) method to the tasks that checks the...

rnowling-memphis

Bug: Review no-member error for ProtoBuf

4

Running Pylint on master generates the following error: ``` memphis/memphis.py:450:23: E1101: Module 'google.protobuf.descriptor_pb2' has no 'FileDescriptorSet' member (no-member) ``` We should fix this or disable it on a per-line basis...

rnowling-memphis

[Discussion] Typing, tests, formatting, pre-commit

4

Hey guys, (memphis-py==0.2.7) I just finished deploying docker-compose demo, played with schema, produced and consumed messages. I would like to contribute and learn project more. Are there any priorities or...

msiwik-epruf