[CAMEL-10696] Allow camel-kafka to resume from any offset

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.19.0
• Component/s: camel-kafka
• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Antoine DESSAIGNE
• Created: 11/Jan/17 15:45
• Updated: 13/Jan/17 13:45
• Resolved: 13/Jan/17 12:02

Description

As Kafka supports resuming from any offsets, it would be nice if this feature was available camel-kafka component.

Since Kafka needs the offset of each partition, its state (where to resume from) should be somehow similar to a Map. We cannot use an IdempotentRepository because it behaves like a Set.

If we create a standard API for holding the state as a Map then we can reuse it for other purpose like resuming database reads from a particular index.

Issue Links

• links to: GitHub Pull Request #1393