A high performance/ real-time C++ Kafka streams framework (C++17)
upgraded thirt party versions - switched back to openssl from boringssl
Cleanup for gcc10, grpc v1.32.0
C++14 -> C++17 lots of refactor. prometheus metrics memory stream source grpc source S3 sink optional external offset storage S3/local file
lots of refactor new sources/sinks in "kafka connect style" but directly usable in transformations
postgres-source sqlserver-source
postgres-sink influxdb-sink elastic search-sink avrofile-sink (work in progress)
new utilities kafka2es kafka2influx kafka2postgres postgres2kafka tds2kafka (sqlserver to kafka) kspp_avrgencpp (extended avrogencpp from apache avro)
docker build for alpine 3.7 (imagesize 42.4MB)
new sources postgres sqlserver
new sinks postgres influxdb elastic search avrofile
new utilities kafka2es kafka2influx kafka2postgres postgres2kafka tds2kafka (sqlserver to kafka) kspp_avrgencpp (extended avrogencpp from apache avro)
docker alpine 3.7 build 42.5MB
Support for left, inner and outer joins