Files
Marc Demierre 8c5d1871db sink: Implement basic Kafka sink
This new sink adds basic support for Kafka, using `sarama.SyncProducer`.

It allows minimal configuration to make it useful:

- Topic
- Broker List
- TLS settings

The layout transformations are supported in the same way as for kinesis.

Implements issue #6.
2019-12-15 14:00:00 +01:00
..
2019-10-29 00:03:31 +03:00
2019-10-29 00:03:31 +03:00
2019-12-09 14:09:26 +03:00
2019-12-15 14:00:00 +01:00
2019-10-29 00:03:31 +03:00
2019-10-29 00:03:31 +03:00
2019-12-15 14:00:00 +01:00
2019-10-29 00:03:31 +03:00
2019-12-09 14:09:26 +03:00
2019-12-09 14:09:26 +03:00
2019-10-29 00:03:31 +03:00
2019-12-09 14:09:26 +03:00