Skip to content

Instantly share code, notes, and snippets.

@yuri1969
Last active November 30, 2023 15:55
Show Gist options
  • Save yuri1969/4780f44ca0f12bdb870e623345d9b791 to your computer and use it in GitHub Desktop.
Save yuri1969/4780f44ca0f12bdb870e623345d9b791 to your computer and use it in GitHub Desktop.
cheat
echo 'security.protocol=SSL' > ~/kafka-client.properties
export KAFKA_HEAP_OPTS='-Xmx2g'
# ./bin/kafka-consumer-groups.sh --bootstrap-server <host:port> --timeout 15000 --command-config kafka-client.properties --group '<consumer_group_name>' --topic '<topic>:<partition>' --reset-offsets --to-offset <offset> --dry-run
./bin/kafka-consumer-groups.sh --bootstrap-server '...amazonaws.com:9094' --timeout 15000 --command-config ~/kafka-client.properties --group 'kestra_executor_main' --topic 'kestra_execution:7' --reset-offsets --to-offset 8915 --dry-run
# append '--execute' to commit
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment