- Follow Simply Distributed on WordPress.com
eBooks on Redis, JAX-RS & more
-
Recent Posts
-
Tag Archives: Kafka
Accessing Kafka on host machine from minikube pods
There are times when you want to access processes running on your host machine e.g. databases etc. from your minikube Kubernetes cluster in Virtual Box (or any other supported provider) For details, continue reading this blog on Medium Cheers!
Kafka Go client: No Producer error during connection ?
Although its rare, but there are times when you actually want to see errors in your code – more importantly, at the right time ! Kafka Go Producer behaviour You need to be mindful of this while using the Kafka … Continue reading
NATS & Kafka: random notes
This is not NATS vs Kafka by any means – just jotting down some info. NATS recently joined CNCF (which host projects like Kubernetes, Prometheus etc. – look at the dominance of Golang here!) and that’s when it caught my attention … Continue reading
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
Debezium test drive
Debezium is an open source, distributed change data capture system built on top of Apache Kafka. I tried it out and the project is available on Github Setup Details are in the README. It uses the Debezium tutorial as a … Continue reading
Posted in Distributed systems, Kafka
Tagged change data capture, debezium, docker, docker compose, javaee, Kafka, mysql
1 Comment
Kafka & Websocket
For those who are interested in an example of Kafka working with the (Java EE) Websocket API, please check out this blog . There is an associated Github project as well Cheers!
Kafka producer and partitions
There are only a few possible ways to specify partitions while using the Kafka Producer API Just specify it in the ProducerRecord itself If key is not null, (by default) Kafka will hash your key and calculate the partition If key … Continue reading
Posted in Distributed systems, Kafka
Tagged Distributed systems, Kafka, partitioning
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
Scaling out with Kafka Consumer Groups
This blog post will cover Apache Kafka consumers and demonstrate how they are designed for distributed, scale-out architectures. It assumes you have some idea about Kafka in general. We will mainly look at Kafka Consumers groups, and dive into the … Continue reading
Posted in Distributed systems, Kafka
Tagged apache kafka, big data, consumer, consumer group, Kafka, messaging, scalability
1 Comment