Questions tagged [apache-kafka]

Apache Kafka is a distributed streaming platform designed to store and process high-throughput data streams.

Filter by
Sorted by
Tagged with
0
votes
1answer
131 views

OOP Refactoring

The following script derives schemas from varied file formats. Can I get this reviewed? What would the improvements look like: ...
0
votes
0answers
39 views

Redesign Kafka serialized communication to use object type per Kafka Topic

I want to implement Kafka Topic which sends and receives Serialized Java Objects based on this example. I tried this: Producer Config: ...
1
vote
0answers
28 views

Implement Kafka Communication with Serialized Java objects

I want to implement Kafka Topic which sends and receives Serialized Java Objects based on this example. I tried this: Producer Config: ...
6
votes
2answers
138 views

Simplify Generic Method

I am writing a GenericDeserializer for Apache Kafka. My class implements IDeserializer<T> from Confluent.Kafka.Net package....
2
votes
1answer
1k views

Spring, Kafka and Mongo how to create a RestController

I'm learning how to use Kafka, I've never used something similar in the past. In my job I was required to create a POC using it and integrate it to Spring Boot and save information on MongoDB (because ...
2
votes
0answers
703 views

Reactive Extensions wrapper around Confluent.Kafka for .NET

Just an Rx wrapper around Kafka to represent topic consumption as IObservable<T>: ...
2
votes
1answer
751 views

Send excel data to Kafka

I would like some one to review my code and let me know the feedback. Each Kafka Message is like as follows [{guid=id.Value1, timestamp=1386394980000, booleanValue=null, longValue=null, floatValue=...
1
vote
0answers
16 views

Node Express App - Create structure around incoming payload [closed]

I am working on a simple NodeJS express app that accepts an incoming payload from a few different systems. There is a single route that ships the data off to another method and waits for the promise. ...
4
votes
1answer
149 views

Autocomplete for Kafka Streams application

I'm building an application that's going to create different autocomplete suggestions of data that sits in Kafka using Kafka Streams application. Data is read from a relational database and looks as ...