This quick tutorial is going to cover how to install Apache Kafka on Windows. 1. Prerequisites Install Java (The latest released version of JDK 1.8 is recommended) 2. Download Apache Kafka Distribution Download an Apache Kafka distribution from its website…. Continue Reading →
As mentioned in previous article, Spring Kafka provides two MessageListenerContainer implementations: KafkaMessageListenerContainer and ConcurrentMessageListenerContainer. The KafkaMessageListenerContainer provides ability to consume messages from Kafka topics in a single thread while the ConcurrentMessageListenerContainer allows us to consume messages in multi-threaded style. In… Continue Reading →
Apache Kafka, a distributed messaging system, is gaining very much attraction today. Spring is a very popular framework for Java developer. Getting Apache Kafka to work with Spring smoothly will be a very good thing for many Java developers. In… Continue Reading →
To continue the series about Apache Flume tutorials, I’d like to share an example about Apache Flume Kafka Source and HDFS Sink. One of popular use case today is to collect the data from various sources, send them to Apache… Continue Reading →
To continue the topic about Apache Kafka Connect, I’d like to share how to use Apache Kafka connect MQTT Source to move data from MQTT broker into Apache Kafka. Note that from the version 0.9, Apache Kafka introduce a new… Continue Reading →
Continue the tutorial series about Apache Kafka, today, I’d like to share how to get Apache Kafka installed by using Apache Kafka Docker. 1. Preparation You first should have latest versions of Docker installed on your machine. If not, you can… Continue Reading →
1. Introduction to Apache Kafka Connect Apache Kafka, which is a kind of Publish/Subscribe Messaging system, gains a lot of attraction today. We can see many use cases where Apache Kafka stands with Apache Spark, Apache Storm in Big Data… Continue Reading →
Here are some commands often be used when we work with Apache Kafka command line interface (CLI). 1. Start the Kafka server We needs 2 steps: 1.1 Start the ZooKeeper
|
1 |
bin/zookeeper-server-start.sh config/zookeeper.properties |
1.2. Start the Kafka server
|
1 |
bin/kafka-server-start.sh config/server.properties |
2. List all… Continue Reading →
To continue the series about Apache Kafka, I’d like to share how to write a custom serializer in Apache Kafka. 1. Why we need a custom serializer in Apache Kafka? Apache Kafka allows us to send the messages with different… Continue Reading →
In this article, I’d like to show you how to create a producer and consumer by using Apache Kafka Java client API. 1. Overview Apache Kafka has some built-in client tools to produce and consume messages against Apache Kafka broker…. Continue Reading →
© 2024 HowToProgram — Powered by WordPress
Theme by Anders Noren — Up ↑