Claudio Fahey

Is your feature request related to a problem? Please describe. Docusaurus uses Markdown documentation with minor differences from mkdocs. Describe the solution you'd like Add Yaml front-matter. Move title from...

Reader Group is not deleted

4

**Problem description** This connector creates a reader group but never deletes it. **Problem location** FlinkPravegaReader.java **Suggestions for an improvement** `FlinkPravegaReader.close()` should call `ReaderGroupManager.deleteReaderGroup()`.

Issue 191: Add at-least-once stream processing example

13

These examples are intended to illustrate how at-least-once semantics can be achieved with Pravega. In particular, these illustrative examples do not use Apache Flink.

Issue 198: Fixes to allow running in Flink examples in SDP

3

- Added Pravega credentials dependency to all projects - Flink JAR can now be published to Nautilus Maven repo. - Hadoop examples can now be run without Hadoop installed. -...

Issue 187: Add MQTT to Pravega bridge sample

3

Add MQTT to Pravega bridge sample. A sample application reads events from MQTT and writes them to a Pravega stream.

Added Pravega credentials JAR. Allow publishing artifacts to Maven repo in Nautilus.

Add an example demonstrating exactly-once processing without Flink.

Add the MQTT to Pravega bridge sample.

Add an example demonstrating writing and reading video using the byte stream API.

Currently, events that consist of strings are serialized in Pravega using JavaSerializer. This is not ideal because 1) it is difficult to use in non-Java environments, 2) it adds unnecessary...