runtime error для конкретного джоба

[anastasija513]

Вот здесь, если запускать скрипт конкретно для ач таска, то он падает с runtime error: invalid memory address or nil pointer dereference:
https://github.com/InnovaCo/samza-checkpoint-tool/blob/master/checkpoint_tool.go#L257

А если брать OffsetOldest, то всё нормально(c -2 начинается):
c, _ := consumer.ConsumePartition(topic, 0, sarama.OffsetOldest)
Почему так, пока разбираюсь

[Kostassoid]

Да, решение с OffsetOldest лучше.
Но вообще -2 это не очень нормально. Похоже на последствия этого бага, если все еще используется Kafka 0.8.x: https://issues.apache.org/jira/browse/KAFKA-3323
Есть риск потери данных.
Но я не копал глубоко, может есть более мирные причины для отрицательных офсетов.

[anastasija513]

интересно, спасибо!