Skip to main content
33,401 questions
Newest Active Bountied Unanswered
0 votes
0 answers
32 views

I'm building a real-time dashboard using FastAPI WebSockets + Kafka. Everything works perfectly for a single user, but when multiple users connect, only the most recently connected user receives ...
PRANAV K P's user avatar
  • 21
Best practices
0 votes
2 replies
38 views

I am designing a system using .NET that acts as a MES system between 200+ pieces of equipment (IoT devices). The flow is bidirectional: Equipment -> My .NET System -> Equipment I need low ...
fancyBobLol's user avatar
  • 13
0 votes
1 answer
38 views

I am trying to install an instance of Conduktor Console using a Docker image, following the instructions from the GitHub page: Console Only: Start Conduktor and connect your own Kafka # Start ...
user2138149's user avatar
  • 18.7k
0 votes
0 answers
20 views

I’m using Apache Pinot and ingesting a large amount of real-time data. Everything works initially, but after some time my queries start slowing down significantly. I’m new to Pinot and not sure what ...
Harry Arif's user avatar
  • 1
0 votes
0 answers
65 views

System is on two site, facing issues on resiliency so using circuit breaker. When I am on close state then sending message to the primary site on call back on secondary site both are using different ...
Anonymous's user avatar
  • 1
1 vote
0 answers
35 views

I have subscribed to a Kafka cluster A with some Kafka engine tables before, and they are working normally. I have created a new Kafka cluster now, but after subscribing to the topics of the new ...
Slim's user avatar
  • 11
Best practices
0 votes
0 replies
30 views

I am reading data from a Kafka topic using Kafka Streams and more specifically GlobalKTable to populate my store. In the case of corrupt data that can not successfully be parsed I wish to throw a ...
Andreas10001's user avatar
  • 23
Best practices
0 votes
7 replies
57 views

I am using Kafka Streams, and trying to figure out the best practice for handling multiple stores that are populated using the same data without having to read it twice. My Kafka Streams service is ...
Andreas10001's user avatar
  • 23
1 vote
0 answers
58 views

Context. I have to use StreamBridge::send() with Kafka. This is a hard, external requirement. The call itself looks like streambridge.send(binding, message). All good. To capture the non-immediate ...
wojas's user avatar
  • 183
Best practices
0 votes
1 replies
55 views

I have an EVDA system that each component communicate to each other using Kafka and Outbox Pattern. How to implement an automated E2E testing that I start producing an event from an upstream, then ...
Bhoomtawath Plinsut's user avatar
  • 1,380
2 votes
1 answer
28 views

Image details: Service Container ID Image Status Ports Name Zookeeper 17025a6f1e4b confluentinc/cp-zookeeper:latest Up 18s 2181,2888,3888 composefiles_zookeeper_1 Kafka 4a0964b3f368 confluentinc/cp-...
Chandan Mahadev Shetty's user avatar
  • 21
0 votes
1 answer
39 views

I am looking for a way to inject Kafka headers into a the message body when using AWS MSK connector. Something similar to: "transforms": "InsertField", "transforms.InsertField....
Sylvester's user avatar
  • 191
0 votes
0 answers
29 views

Apache NIFI 2.5.0 KafkaPublisher can not publish message larger than 30 MB. I have adjust the Max Request Size to 50MB but still in vain. The topic on Kafka has config the message size to 50 MB. I ...
wureka's user avatar
  • 923
Best practices
0 votes
0 replies
54 views

I have two Spring Kafka consumers that process batches of messages with manual acknowledgements. This setup has been running correctly for a long time with AckMode.MANUAL_IMMEDIATE. Recently, I ...
M2bar's user avatar
  • 3
1 vote
0 answers
68 views

I’m trying to integrate Oracle GoldenGate for Big Data (Kafka Connect handler) with Confluent Kafka running in Docker. The handler starts successfully, trail files are read, and mapping works — but ...
Mendbayar Alzakhgui's user avatar
  • 11

15 30 50 per page
1
2 3 4 5
…
2227