We are using KSQL Version 0.23.1. We are seeing OOM issues on ksql cluster which has persistent stateless stream. Stream is just doing the point filtering on th
I have setup flink operator and kafka on minikube (both are on different namespaces). I am trying to consume messages from a kafka topic in flink and do some tr
We have created a .NET Worker.cs to consume kafka topics. What should be the best way to consume multiple topics? Our requirement is there are multiple topics,
I have a scenario where I need to call an api to the notification service which will send an email to the user. Based on the message that appears to the topic I
I am using Kafka and facing a problem. Kafka doesn't seem to work locally using minikube. I get this erorr: org.apache.kafka.common.errors.InvalidReplicationFac
I tried many of similar solutions - had no luck. I'm using Ubuntu 20.04, following this Confluent tutorial I've managed to get everything running several times
I have WSO2 EI 6.6.0 and I am using the next libs to configure Kafka Inbound Enpoint. dropins: org.apache.synapse.kafka.poll-1.0.10.jar lib: kafka_2.12-1.0.0.
How should it be configured the spring-cloud-schema-registry-client to communicate with Confluent Schema Registry on a secured manner using SSL truststore? My c
I have set up a docker network with: 4 producer containers (each scraping a different forum) that produce to a Kafka container (1 topic for each of the forum) A
we have project using kafka and kafka stream, recently we found OOM issue happen for the project, after analysis the dump file, we found that too many 'org.apac
I am using the spring cloud contrat to test a kafkaListsener of my service. I use EmbeddedKafka together with the spring cloud contract. The listener in my serv
Kafka deployed through istio cannot be provided to the k8s cluster for external access with the following error Error connecting to node kafka-0.kafka-headless
Getting below error message when producing record to Azure event hub(kafka enabled) Expiring 14 record(s) for eventhubname: 30125 ms has passed since batch cre
Step 1. Postgres CDC Data I have a Postgres table which has been set up to use Debezium PostgreSQL Connector to generate CDC. In Kafka, I can see the CDC data i
I'm using kafka to send the multiple collections data into a single topic using mongo source connector and upsert the data into different oracle tables using jb
I started to dive into kafka ecosystem. I was surprised to find out that by default, each consumer only digests one "event" at a time, sequentially! It's given
Background Our software solution collects data ("events") per customer. Some of the customers (a small fraction ~3%) ask to get this data into "their systems" (
I didn't find an answer to my question so far so I'm giving it a try here. Let's assume a Spring Batch application with remote partitioning. There's one master/
I'm experimenting a lot with Apache Kafka in a Spring Boot App at the moment. My current goal is to write a REST endpoint that takes in some message payload, wh
I'm running Confluent Platform in wsl 2(Ubuntu Distribution) and I also running a Spring application on Windows but when I send a message with a producer I have