Saturday, January 12, 2019

Consuming from specific Offset, in a Topic, with Confluent Kafka .Net client


From the example in the home page help here https://github.com/confluentinc/confluent-kafka-dotnet#basic-consumer-example 

Change below
c.Subscribe("my-topic");

and update it as below (assuming topic is "my-topic" and offset is 123456)

c.Assign(new TopicPartitionOffset(new TopicPartition("my-topic", new Partition()), new Offset(123456)));


No comments:

Turn on Windows 11 Fast Boot

If windows starting is slow, to enable windows 11 fast startup/boot,  Press Windows + R, type powercfg.cpl, and hit Enter.  This will direct...