thspinto

#!/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 () {

thspinto

#!/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"

thspinto

kafka-topics --topic TestTopic --describe --zookeeper zk1:2181

thspinto

#!/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)"