Open CMDMichalKoval opened 5 months ago
2024-02-07 23:48:38,289 New partitions assigned: {Partition(topic=Topic(name='events'), index=0): 10090059}
this tells you which message is bad. can you dump the message on that offset? it should be possible to do so with kafkactl/kcat
as a hotfix you can also delete the consumer group using kafkactl and run with --auto-offset-reset latest
, this will basically "flush the queue"
Environment
What version are you running? 24.1.1
Steps to Reproduce
Expected Result
Not crash.
Actual Result
Consumer snuba-consumer crashes with error
snuba-metrics-consumer: