Skip to content

Instantly share code, notes, and snippets.

@isopropylcyanide

isopropylcyanide/connector-encountered-ce-unknown-schema.sh

Last active February 3, 2023 08:12
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save isopropylcyanide/a14cdd93005335b46339245795b2d708 to your computer and use it in GitHub Desktop.
Save isopropylcyanide/a14cdd93005335b46339245795b2d708 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
connector-encountered-ce-unknown-schema.sh
# Find the partition that contains messages from this connector name. Usually by grepping
kafkacat -C -Z -b localhost -t <connect.offsets.topics> -o <number> | grep "servername"
# Set an null offset.
echo '["<connector-name",{"server":"<servername>"}]|' \|
kafkacat -P -Z -b localhost -t <connect.offsets.topics> -K \|
-p <partition>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment