kafka-topics --topic TestTopic --describe --zookeeper zk1:2181
Thiago Pinto thspinto
thspinto
/ env-import
Last active
August 3, 2017 00:04
Import dcos enviroment variables from aws instance tags
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| #!/bin/bash | |
| if [ ! -f /opt/mesosphere/bin.quinto/aws ]; then | |
| echo "Installing awscli" | |
| # Install AWS CLI | |
| /opt/mesosphere/bin/pip install awscli -t /opt/mesosphere/bin.quinto/ | |
| fi | |
| tag="### Custom Envs ###" | |
| tagline="$(grep -n "$tag" /opt/mesosphere/environment | cut -d : -f 1)" |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| #!/bin/bash | |
| team="teamname" | |
| org="orgname" | |
| repos=$(hub api orgs/$org/repos --paginate | jq -rc '.[] | select(.archived == false and .disabled == false) | .name') | |
| IFS=$'\n' | |
| for repo in $repos | |
| do | |
| echo "Adding $repo" |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| #!/bin/bash | |
| BOOTSTRAP_SERVER=kafka:9092 | |
| function reset_offsets() { | |
| local GROUP=$1 | |
| local TOPIC=$2 | |
| kafka-consumer-groups.sh --bootstrap-server $BOOTSTRAP_SERVER --group $GROUP --topic $TOPIC --reset-offsets --to-latest --execute | |
| } | |
| function main () { |