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:
Post a Comment