helpermethod/kafka-connect-source-connector-reset.md

Last active September 29, 2020 13:19

Star (0) You must be signed in to star a gist
Fork (0) You must be signed in to fork a gist

Learn more about clone URLs
Clone this repository at <script src="https://gist.github.com/helpermethod/0fc934df287477a28ffe78a897ce3c05.js"></script>
Save helpermethod/0fc934df287477a28ffe78a897ce3c05 to your computer and use it in GitHub Desktop.

Kafka Connect Source Connector Reset

Raw

kafka-connect-source-connector-reset.md

kafkacat -q -e -b localhost:9092 -t connect-offsets -f '%p#%k\n' | {
  while IFS=# read -r partition key; do
    # replace connector_name with the actual connector name
    if [[ $key =~ '["connector_name",' ]]; then
      echo "echo '$key#' | kafkacat -b localhost:9092 -t connect-offsets -P -Z -K# -p $partition" && exit
    fi
  done
}