Tag Archives: kafka

Deep dive into Kubernetes components required to run stateful Kafka Streams applications

Happy to get feedback via @abhi_tweeter or just drop a comment! One of the previous blogs was about building a stateless stream processing application using the Kafka Streams library and deploying it to Kubernetes as in the form of a … Continue reading

Posted in kubernetes | Tagged , , | Leave a comment

Tutorial: Develop a Kafka Streams application for data processing and deploy it to Kubernetes

This tutorial will guide you through how to build a stateless stream processing application using the Kafka Streams library and run it in a Kubernetes cluster on Azure (AKS). As you go through this, you’ll learn about the following: What … Continue reading

Posted in kubernetes | Tagged , , , , | 1 Comment

How to quickly test connectivity to your Azure Event Hubs for Kafka cluster, without writing any code

You have a shiny new Kafka enabled broker on Azure Event Hubs and want to quickly test it out without writing cumbersome client (producer and consumer) code. Try out the instructions in this post and you should (hopefully) have everything … Continue reading

Posted in Java EE | Tagged , , | Leave a comment

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 Cloud, Java EE | Tagged , , , , , , , | Leave a comment

Java EE + Debezium

I just published a post – Debezium test drive. It uses Kafka and Java EE… check it out if this interests you Cheers!

Posted in Java, Java EE | Tagged , , , , , , | Leave a comment

kafEEne #2: Kafka & Concurrency Utilities

Yet another blog post of the kafEEne series – this time, its Java EE Concurrency Utilities in action along with Kafka. As usual, the code is on Github and you can refer to the README on how to get this up … Continue reading

Posted in Java EE | Tagged , , , , , , | Leave a comment

Consume from Kafka topics using Message Driven Beans

Thanks to the recently released Payara Kafka Connector, you can now consume messages from Kafka using Message Driven Beans! Here is a Docker based example for trying it out. Quick overview A @Singleton bean fires a producer process which run in … Continue reading

Posted in Java EE | Tagged , , , , , , | 2 Comments

kafEEne #1: Websocket & Kafka

Say hello  to kafEEne ! A blog series which will show Kafka and Java EE examples This one is about Kafka + (Java EE) Websocket API. Code is on Github and you can refer to the README on how to get this … Continue reading

Posted in Java EE | Tagged , , , , , , , | 1 Comment