Skip to content

Kafka gateway: Kafka ListOffsets API (key 2) — earliest/latest via Iggy high watermark #3537

Closed

Description

@ryerraguntla

Part of #3560.

Summary

Implement Kafka ListOffsets (API key 2) using IggyBridge::high_watermark() and earliest offset resolution.

Motivation

Clients call ListOffsets before Fetch to resolve -1 (latest) and -2 (earliest) timestamps/offsets.

Depends on

Scope

  • Support timestamp types: earliest, latest (scoped versions)
  • Per-partition offset in response; error code per partition on failure
  • Tests: empty topic, topic with messages, invalid partition

Acceptance criteria

  • Java/librdkafka client can resolve offsets before fetch
  • ListOffsets consistent with Fetch high-watermark

References

Activity

  1. added
    gatewaysproxy gateways for other protocols like kafka
    on Jun 23, 2026
  2. changed the title [-]feat(gateways): Kafka ListOffsets API (key 2) — earliest/latest via Iggy high watermark[/-] [+]Kafka gateway: Kafka ListOffsets API (key 2) — earliest/latest via Iggy high watermark[/+] on Jun 24, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

Labels

gatewaysproxy gateways for other protocols like kafka

Type

No type

Projects

No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions