RJ Nowling
RJ Nowling
### Current behavior When creating a consumer group, the user can specify the starting sequence id. Once a consumer group is created, however, it's not possible for the user to...
### Current behavior When using the Python SDK, if a message fails schema validation, an exception is raised. I see a couple of issues: 1. This is a bit confusing...
### Current behavior Currently, messages can only be produced one at a time. When working on the data uploader for the Zakar hackathon, I found that it takes quite a...
### Describe the bug The schemaverse UI has an option for generating a schema from an example JSON document. After trying it with a simple example, I pasted the following...
### Current behavior The documentation and UI both refer to specifying a schema for JSON. That said, it's not clear if it's using the official JSON Schema specification or not....
### Current behavior The documentation for schema verse configuration for JSON does not describe what the "Convert to JSON Schema" button does or provided examples for how to use it....
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...
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...
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...
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...