diff --git a/internal/storage/githubstorage/githubstorage.go b/internal/storage/githubstorage/githubstorage.go index 336eecd..e16a741 100644 --- a/internal/storage/githubstorage/githubstorage.go +++ b/internal/storage/githubstorage/githubstorage.go @@ -60,6 +60,8 @@ type GitHubStorage struct { func (GitHubStorage) prepareGitHubPayload(message *sarama.ConsumerMessage) (*GitHub, error) { githubStorage := new(GitHub) + githubStorage.KafkaPartition = message.Partition + githubStorage.KafkaOffset = message.Offset deliveryID, err := uuid.Parse(string(message.Key)) if err != nil {