Fix kayrock stream skips first message

kafkaex / kafka_ex

Kafka client library for Elixir

MIT License

596 stars 162 forks source link

Fix kayrock stream skips first message #392

Closed semarco closed 4 years ago

semarco commented 4 years ago

With the new Kayrock client, when KafkaEx.stream internally fetches and receives a response with an empty message set, it increased the stream's offset by one.

Thus, it skipped the first message in this case.

sourcelevel-bot[bot] commented 4 years ago

Hello, @pixelvitamina! This is your first Pull Request that will be reviewed by SourceLevel, an automatic Code Review service. It will leave comments on this diff with potential issues and style violations found in the code as you push new commits. You can also see all the issues found on this Pull Request on its review page. Please check our documentation for more information.