eBooks on Redis, JAX-RS & more
-
Tag Archives: kafka streams
Session @ Oracle Code San Francisco 2017
Here are the details for my talk @ Oracle Code (a track at JavaOne 2017) – Streaming Solutions for Real time problems (Stream Processing solutions using Apache Kafka, Kafka Streams and Redis) Code (Github) – https://github.com/abhirockzz/accs-ehcs-stream-processing Video Slides Streaming Solutions for … Continue reading
Posted in Distributed systems, Kafka
Tagged javaee, Kafka, kafka streams, nosql, oracle application container cloud, oracle cloud, oracle jet, paas, redis, stream processing
Leave a comment
Kafka Streams state stores…
This blog explores some common aspects of state stores in Kafka Streams… Default state store By default, Kafka Streams uses the RocksDB as it’s default state store In-memory or persistent ? This parameter of the state store is configurable. RocksDB can … Continue reading
Posted in Distributed systems, Kafka
Tagged apache kafka, Distributed systems, kafka streams, state store, streaming
3 Comments
Docker-ized Kafka Streams applications
Here is another example of a Kafka Streams based application.. this time, it’s about running it in Docker containers – spawn more containers to distribute the processing load. More details in the README Cheers!
Posted in Distributed systems, Kafka
Tagged apache kafka, Distributed systems, docker, kafka streams, stream processing
Leave a comment
Tip: ClassCastException in Kafka Streams reducer
If you use the groupByKey function on a KStream without specifying a Serdes, the (one configured in the StreamsConfig will be used by default e.g. in the below snippet, it’s Serdes.String(). As a result, you will face a ClassCastExcpetion in case you execute … Continue reading
Posted in Distributed systems, Kafka
Tagged consumer, Distributed systems, Kafka, kafka streams, reducer, stream processing
Leave a comment
Simply Distributed 