Skip to content

Instantly share code, notes, and snippets.

View fjbsantiago's full-sized avatar

Francisco Santiago fjbsantiago

View GitHub Profile
#
# Get 1 single record from topic by partition Nr and Offset Nr
#
# Hint 1: Execute using running schema-registry container
# Hint 2: If possible, stop any producers that might cause kafka to delete or tombstone records in this topic (don't really know if tombstone records become inaccessible, but... just to be sure)
#
docker exec -it schema-registry kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic topic-name --max-messages 1 --property print.key=true --offset 71403579 --partition 1