Questions tagged [kafka-net]
5 questions
3
votes
0 answers
Task hang infinitely when calling .Wait() in kafka-net
I'm currently trying to post messages from a for-loop on a kafka server running on my local machine using the kafka-net library in c# (https://github.com/Jroland/kafka-net), following the example given on the linked repo, my code is the…
Silvio Zanoli
- 78
- 7
1
vote
1 answer
Kafka and C# - Send Message To Specific Partition
I run Kafka with Docker,
First I created a topic like this,
docker exec -t kafka kafka-topics --bootstrap-server :9092 --create --topic kafka-test --partitions 5 --replication-factor 1
As you see, there are 5 partitions, I used the code below
I…
serhatyt
- 180
- 2
- 14
1
vote
0 answers
Jroland/kafka-net Group Id assignment in Consumer
I'm trying Kafka c# client libraries.
First, I built a basic producer and consumer app in confluent-kafka-dotnet and honestly, it covered my needs, though, I wanted to give a try to kafka-net library.
But I couldn't find a way to consume values by…
ibrahimozgon
- 1,137
- 1
- 12
- 19
0
votes
2 answers
How to get only the latest message of a Kafka topic?
Is there a way to decompose the messages so that only the latest message is consumed?
I tried to save the messages in a list, but it didn't really work out
var consumer = new Consumer(new ConsumerOptions(topic, router));
foreach (var message in…
point
- 290
- 3
- 12
-1
votes
1 answer
How to consume kafka messages from last saved offset
I'm new to kafka and have been trying to implement a consumer. Below is my scenario
start consumer application
produce messages from producer. these messages are consumed by consumer
stop the consumer and produce messages again. when I start the…
sunil kumar
- 1
- 2