79374142

Date: 2025-01-21 11:11:33
Score: 0.5
Natty:
Report link

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);
                        });
Reasons:
  • Long answer (-0.5):
  • Has code block (-0.5):
  • Self-answer (0.5):
  • Low reputation (1):
Posted by: Nikita Berezhko