Как искать начало темы?

Question

В C # как ты это делаешь?Библиотека, кажется, не соответствует некоторым другим реализациям.

Я думал что-то вроде

using (var c = new Consumer<Ignore, string>(conf)) {

    c.Subscribe(topic);
    c.Assignment
       .ForEach(partition => c.Seek(new TopicPartitionOffset(partition, Offset.Beginning)));
}

, но изначально никаких назначений нет.Если я перехватываю событие для OnPartitionsAssigned, потребитель все еще не имеет назначенного раздела, и, хотя у события есть раздел, потребитель не может его искать.

Я полагаю, что есть стандартспособ сделать это, но я не уверен, что это такое.

Answer 1

Было бы что-то вроде этого.Вы должны просто знать о номере раздела, который здесь 0:

using (var c = new Consumer<Ignore, string>(conf)) 
{
    TopicPartitionOffset tps = new TopicPartitionOffset(new TopicPartition("TOPIC", 0), 
    Offset.Beginning);
    c.Assign(tps);
}