This project contains examples which demonstrate how to deploy analytic models to mission-critical, scalable production environments leveraging Apache Kafka and its Streams API. Models are built wi…

open-source trading framework for java, supports backtesting and live trading with exchanges

Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response

Demo application to show how to pipe messages from kafka to a websocket endpoint

a configurable custom policy for Apigee, which performs AES encryption or decryption.