Questions tagged [apache-kafka]
Apache Kafka is a distributed streaming platform designed to store and process high-throughput data streams.
9 questions
3
votes
1
answer
93
views
Consuming each Kafka partition in a separate proccess
I'm reimplementing functionality originally written in Kotlin. It uses Dispatchers.Default which is recommended for CPU-intensive tasks like JSON parsing to start ...
2
votes
1
answer
98
views
Asynchronous mailing tool
I'm trying to change my sync code to asynchronous.
It's my first time doing it like this, so I don't know if this is the right way.
...
- 21
3
votes
1
answer
1k
views
Convert a c# decimal to big-endian byte array
Following the avro schema documentation for decimals I've created a method to turn a decimal into a byte array. The goals are:
Should be represented by a non-scaled integer
Should be big-endian
I've ...
- 155
1
vote
1
answer
199
views
OOP Refactoring
The following script derives schemas from varied file formats. Can I get this reviewed? What would the improvements look like:
...
- 157
7
votes
2
answers
494
views
Simplify Generic Method
I am writing a GenericDeserializer for Apache Kafka. My class implements IDeserializer<T> from Confluent.Kafka.Net package....
- 296
3
votes
1
answer
3k
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 ...
- 191
3
votes
0
answers
1k
views
Reactive Extensions wrapper around Confluent.Kafka for .NET
Just an Rx wrapper around Kafka to represent topic consumption as IObservable<T>:
...
- 173
3
votes
1
answer
2k
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=...
- 31
4
votes
1
answer
233
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 ...
