repo: yolean/kubernetes-kafka I'm going to follow the steps to deploy a kafka cluster in cloud....
I am trying to do a left join on 2 Kstreams coming from 2 different topics - stream1 & stream2,...
so I have a SpringBoot end point controller that starts like this: @RequestMapping(value =...
Need some help figuring out issues setting up kafka cruise control with kafka cluster with 3...
I've tried setting up Zookeeper on the EC2 instance and then connecting Kafka 2.11-1.1.0 from both...
I am trying to understand the difference between joinWindows.of vs joinWindows.until while doing a...
The console commands of kafka-console-producer.sh and kafka-console-consumer.sh are functioning...
We looking at Kafka Streams as a way to solve comparisons in flight. Specifically, we have data...
Is there any approach to find by what rate kafka consumer is consuming messages? Like 5000...
Say if auto-commit interval time is 30 seconds, consumer for some reasons could not process the...
I'm new in node js. I'm writing a microservice which listening kafka messages and save data to...
I have a data stream like : DataStream[myTuple(topic, value)] And I wanted to send a specific...
I have been playing around with Kafka (1.0.0) for a couple of months and trying to understand how...
i started zookeeper and Kafka server in Linux machine. Both servers are started successfully. After...
I have the following code and I'm wondering why it generates only one batch: df =...
I am working on kafka and spring boot application. I am writing a file to drive using java File...
I am new to kafka. Is there any API to list the result same as kafka-consumer-groups.sh/bat file...
I am consuming data from a couple of topics(topic_1, topic_2) using KTable, joining the data and...
Step 1: create Topic with only one partition: bin/kafka-topics.sh --create --zookeeper...
A recommended setting for JVM looks like following -Xmx8g -Xms8g -XX:MetaspaceSize=96m...
Here's the list of my connector plugins: > curl localhost:8083/connector-plugins { "class":...
Studying kafka in the documentation I found next sentence: Queuing is the standard messaging type...
I am trying to read the message from Kafka using consumer with the following...
I'm using Spark 2.3 to do some structured streaming test. I checked the jars I used, but only...
I have a SPARK streaming application which reads continuous incoming data from a kafka direct...
When using a Kafka ordering service in Hyperledger Fabric each channel is mapped to a Topic with a...
Background: We had previously used hibernate search, Lucene and jboss hornetq queue for...
I have a docker image as located here https://github.com/Landoop/fast-data-dev which has all the...
When I load the .jar file in Spark I have the following error: Exception in thread "main"...
To create a kafka streams state store in Java I can do this: final KGroupedStream<String,...