{"push_id":1141416256,"size":1,"distinct_size":1,"ref":"refs/heads/GH-89","head":"bc54cdf382f8c26beadfe3676ee1728b86d49981","before":"252a3022a46065444882b47f5943d62a1f809bc8","commits":[{"sha":"bc54cdf382f8c26beadfe3676ee1728b86d49981","author":{"name":"Artem Bilan","email":"4246cd662ae7a06ed197fce2d6dc6195739576a9@pivotal.io"},"message":"GH-89: Add support for `seek` from the beginning\n\nFixes GH-89 (https://github.com/spring-projects/spring-kafka/issues/89)\n\n* Introduce `TopicPartitionInitialOffset`, where it utilize `TopicPartition` and `Long initialOffset`\n* The `initialOffset` can be:\n  - `null` - do nothing; rely on the `auto.offset.reset` of `Consumer` config;\n  - positive (including `0`) - absolute offset from the begging of partition;\n  - negative - the offset from the end of partition: `consumer.seekToEnd() - initialOffset`\n* Rework everything around to rely on a new `TopicPartitionInitialOffset` abstraction\n* The logic in the `KafkaMessageListenerContainer.ListenerConsumer.initPartitionsIfNeeded()` reworked to in favor of a new abstraction\n* remove redundant `recentOffset`\n* Reflect new `TopicPartitionInitialOffset` in the docs","distinct":true,"url":"https://api.github.com/repos/artembilan/spring-kafka/commits/bc54cdf382f8c26beadfe3676ee1728b86d49981"}]}
{"actor":{"display_login":"artembilan"}}