Skip to content

Latest commit

 

History

History
43 lines (39 loc) · 1012 Bytes

consumer.md

File metadata and controls

43 lines (39 loc) · 1012 Bytes
Raw

consumer

Configuration

(config precedence)

  • --interactive
    • Type: Boolean
    • Prompt for missing configuration
  • --kafkaAuth
    • Type: String
    • Type of auth to use for Kafka connection ('none' or 'IAM')
  • --kafkaHost
    • Type: String
    • Host of Kafka instance
  • --consumerGroupId
    • Type: String
    • ID of consumer group
  • --topic
    • Type: String
    • Topic name

Fetch consumer offsets

kafka-tools consumer fetch-offsets

Reset consumer offsets

kafka-tools consumer reset-offsets

Configuration

  • --earliest
    • Type: Boolean
    • Reset offsets to the earliest offset
  • --latest
    • Type: Boolean
    • Reset offsets to the latest offset
  • --timestamp