I am trying to load the data from Kafka to Oracle using JDBC sink connector. I am trying to...
I am considering Kafka to stream updates from the back-end to the front-end applications. - Data...
I have a single node kafka broker and single node zookeeper with the server.properties like below...
I'm new to Kafka/AWS.My requirement to load data's from several sources into DW(Redshift). One of...
I'm trying to read all of the records from a Kafka Topic in Flink. With the following setup it...
I have some historical data, each record has their timestamp. I would like to read them and feed...
I try to shift back the offset of topic within consumer group using following...
I'm writing a program in scala for spark streaming connection with kafka and I'm getting the...
I am trying to setup filebeat (6.2) with kafka output using lz4 compression, but always getting...
Started Zookeeper with the following properties ie zookeeper.properties ...
In my simple application i am trying to instantiate a KafkaConsumer my code is nearly a copy of the...
Currently I'm working on spark-streaming project. Just starting, and I am still newbie in...
I am using a dockerized static Kafka cluster having 3 brokers. The problem with this cluster is...
I try to run First network sample (v1.1.0-preview) from official docs with kafka orderer type. I...
Hi all, my question is if kafka-python library a pure python or have some C coding?
Can someone show me how to connect my kafka server to a jdbc postgresql database and retrieve data...
I'm writing messages along with timestamps to kafka. If I retry, the timestamp might change, and...
ERROR [main] (DsHandler.java:293) - Unable to set property on handler 'kafkahandler'...
I'm trying to build a C++ static Kafka library for MacOS using this implementation:...
I'm using a projectionFn for the KafkaSource in order to parse a JSON string as my kafka message...
I am trying to setup kafka-connect-cassandra on an AWS instance. I have setup plugin.path in...
I'm using the kafka-node client and I'm trying to understand the kafka protocol. I have this basic...
My use case is to create a Producer using Apache Hive table records and send it to a Kafka Topic....
We are running kafka connector java repo(executable JAR with dependencies using Maven) which...
I'm trying to run Kafka message queue on Windows. I'm usin this tutorial -...
I want to create a scalable kafka cluster, but each kafka instance needs a unique broker ID. What...
My project is structured in such a way that the build job in Jenkins is triggered from a push to...
I have a kafka consumer that does a poll every 10 seconds. I am using wireshark to monitor my...
I'm in the process of making the case for our data forwarding job to switch from Spark batch to...
I have a simple java producer like below public class Producer { private final static String...