I have been reading about kafka security and looks like ACKLs is the way to go to have a secure...
My Kafka cluster has the next configuration. Kafka version cluster (v1.1.0) with 3 brokers One...
I have a Kafka Topic with only one partition and I am not getting what will happen in following...
I am trying to write a Sppark structured streaming job that reads for Kafka topic. The Kafka...
I want to deploy a Kafka cluster and i want some suggestion about broker configs. I'm really...
I'm trying to compile code for integration test classes found in Confluent GitHub -...
I have a lot of topics created without a key, how i can modify them and add the proper one? I need...
I am using pykafka for consuming message and now I am using balanced_consumer for consuming message...
We are using Kafka version 0.10.2.0 and spring boot Kafka version 1.1.8. We have 3 partitions and...
The challenge is to create a Kafka producer that connects to a Kafka cluster that lives within a...
I was timing some transactional code, to see where I was losing the most time. The time taken is...
We currently have the following setup: Spark 2.3.0 Kafka 1.0.0 Kerberos We would like to read...
I am new to Kakfa and learning on to produce and consume messages to and from a Kafka Topic. I am...
I'm trying to make a Web API in a Docker container that will be shipped into an OpenShift...
Context: We have a requirement where I need to capture a specific transaction using KafkaConsumer...
I am developing a microservice where in i am required to query two different microsercvices by...
I have a spark streaming job that run on EMR, read messages from Kafka and output to S3. I use...
I am using RD Kafka C based Client to consume/produce messages to Kafka Broker. It was working fine...
I'm looking at the KafkaConsumer source code here. From looking at the source code (which is in...
I am doing data replication in alpakka using Consumer.commitableSource. But, the size of kafka log...
Can't make any example compile let alone work. What am I doing wrong? Started off from the...
I have installed Kafka on docker swarm, But I am continuously facing below issue. Can anyone shed...
My Main Question: Why is the schema-registry crashing? Peripheral Question: Why are two pods...
Following instruction on "Integrating Kafka and Storm: Code Examples and State of the Game" -...
Is Apache Helix capable of rebalancing data between nodes? For examle I'm developing an in-memory...
We use Hyperledger fabric backed by CouchDB to store records with a lot of text. We want to build a...
I am trying to use kakfa console producrr. It seems that by default, it usses the string...
Hi I have kafka consumers consuming data. The below command gives me consumer group command...
I'm doing the following: var listTopicOptions = ListTopicsOptions().listInternal(false) ...
I've written a stream that takes in messages and sends out a table of the keys that have appeared. ...