It looks like I've found a solution. It was necessary to configure consumer in a similar way (set EnableAutoOffsetStore = false
):
k.TopicEndpoint<ConfirmationTokenCreated>("confirmation-token-created-topic", "group1",
e =>
{
e.EnableAutoOffsetStore = false;
e.EnablePartitionEof = true;
e.AutoOffsetReset = AutoOffsetReset.Earliest;
e.CreateIfMissing();
e.ConfigureConsumer<ConfirmationTokenCreatedConsumer>(context);
});