I downloaded Kafka on my local pc (windows) for development and it comes with zookeeper in it, when...
Performing a select on Clickhouse, on a MergeTree table that is loaded from a KafkaEngine table via...
Using spring-integration-kafka 2.3.0 and Kafka 0.11.0.2. I have configured Kafka for SSL encryption...
I'm trying to get an Apache Apex application running using Apache Beam that reads data from Kafka...
Currently we are using Apache NiFi to consume messages via Kafka consumer. Output of kafka consumer...
I want to implement general Kafka serializer/deserializer based on Avro. It should be general...
I use KafkaEmbedded for my consumer unit tests, where I have two create two different producers...
I would like to stop a App that has a KafkaListener after some time without receiving messages...
I am testing spark structured streaming use kafka.i have a kafka-broker(0.10.1) on host28,default...
I want to send data to Kafka using Python Kafka connector. Everything works fine when I run the...
6 hours ago

Kafka on Nest.JS

from the official Nest.JS docs we can see that We don't support streaming platforms with log...
I try to deploy a Hyperledger Fabric cluster with 2 peers, 2 orderers, 4 kafkas and 3 zookeepers on...
High Level Issue I am running kafka locally and I am using a compacted topic. When I run the...
We are using Kafka connect S3 sink connector that connect to Kafka and load data to S3 buckets.Now...
i had tried php-rdkafka, but it seems it doesn't support synchronous push. What is the best method...
I am trying a POC for Kafka in my project and created two console apps in .net core 2.1 using...
I have the following Kafka producer code. I want to know if I can send image file instead of JSON...
I'm trying to unit test some Kafka code with Spock and I'm having trouble stubbing the response to...
The problem When I issue a go run main.go I get many duplicate symbol errors like duplicate...
I'm using Kafka. I have list with 10k jsons, Currently i'm send the Jsons as follow: for(int i=0...
I have a REST api written in java and want to avoid any extra queries to the database or other...
I have a CentOS 7.5 VM running and I am trying to run a ZooKeeper/Kafka server into a container...
I am trying to work with Kafka for data ingestion but being new to this, i am kind of pretty much...
I am using Spotify docker version of the Kafka. I am having right now a single producer and one...
I'm facing some difficulties while trying to start ZooKeeper, Kafka and schema registry via :...
I try to run example app using confluent-kafka-dotnet inside Docker container, and it works fine...
I am here asking about closing a kafka consumer. Do I need to close kafka consumer even if the...
While playing around with Spring Cloud Stream, Kafka, Debezium and Postgresql I am facing the...
I need to read data from multiple topics in Kafka broker and store the data in Dynamo DB. Any...