Mathieu Rossignol

Support for structured stream checkpointing on azure filesystem

3

Also used to store the current kafka offset while writing to the structured stream sink

Integrate reworked documentation (developer...) into new documentation site

2

This issue #466 has introduced a refactoring of the documentation. This work has been merged into the develop branch with the PR #471. But between the time where this PR...

...as a structured stream service to allow reading/writing to/from Azure event hubs (through AMQP).

Support azure databricks environment

MongoDB and Solr Service sinks may retain some records under some conditions

1

In MongoDB as well as Solr Services, we use the take() method on the BlockingQueue queue, waiting for incoming records. This may lead to some records not flushed into the...

And identify potential other processors that should end up there.

The ES processor allows to put some documents in ES, but does not allow to set ES mapping nor dynamic templates. Instead of creating mapping or dynamic template by hand...

In the index-apache-logs.yml config file, the stream for the SplitText processor has the following config key: avro.output.schema: > { "version":1, "type": "record", "name": "com.hurence.logisland.record.apache_log", "fields": [ { "name": "record_errors", "type":...