Get partition transactions

View as Markdown
GET /v1/partitions/{namespace}/{topic}/{partition}/transactions

Get all transactions for a partition.

Path parameters

  • namespace string Required
  • topic string Required
  • partition integer Required

Responses

  • 200 application/json

    Partition transactions response

    Hide response attributes Show response attributes object
    • active_transactions array[object]

      Active transactions

      Transaction details

      Hide active_transactions attributes Show active_transactions attributes object
      • lso_bound integer(int64)

        First offset

      • producer_id object

        Producer identity

        Hide producer_id attributes Show producer_id attributes object
        • epoch integer(int64)

          Producer epoch

        • id integer(int64)

          Producer id

      • staleness_ms integer(int64)

        How long transaction does not make progress

      • status string

        Transaction status

      • timeout_ms integer(int64)

        Transaction timeout

    • expired_transactions array[object]

      Expired transactions

      Transaction details

      Hide expired_transactions attributes Show expired_transactions attributes object
      • lso_bound integer(int64)

        First offset

      • producer_id object

        Producer identity

        Hide producer_id attributes Show producer_id attributes object
        • epoch integer(int64)

          Producer epoch

        • id integer(int64)

          Producer id

      • staleness_ms integer(int64)

        How long transaction does not make progress

      • status string

        Transaction status

      • timeout_ms integer(int64)

        Transaction timeout
GET /v1/partitions/{namespace}/{topic}/{partition}/transactions 
curl \ --request GET 'http://localhost:9644/v1/partitions/{namespace}/{topic}/{partition}/transactions'
Response examples (200) 
{ "active_transactions": [ { "lso_bound": 42, "producer_id": { "epoch": 42, "id": 42 }, "staleness_ms": 42, "status": "string", "timeout_ms": 42 } ], "expired_transactions": [ { "lso_bound": 42, "producer_id": { "epoch": 42, "id": 42 }, "staleness_ms": 42, "status": "string", "timeout_ms": 42 } ] }