💥 🚀 封装sparkstreaming动态调节batch time(有数据就执行计算)；🚀 支持运行过程中增删topic；🚀 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。

Kafka Examples focusing on Producer, Consumer, KStreams, KTable, Global KTable using Spring, Kafka Cluster Setup & Monitoring. Implementing Event Sourcing and CQRS Design Pattern using Kafka

A Kafka docker container with SSL enabled.

Create a SSL Kafka Cluster with SASL Authentification using his own CA

It is ensured that the necessary certificates are created to encrypt the traffic between Kafka Brokers and clients.

Easy multi-node SSL Kafka for Kubernetes

Sample of Kafka client Properties for Producer and Consumer