added .bash.d/kafka.sh

.bash.d/kafka.sh

@@ -0,0 +1,50 @@
+#!/usr/bin/env bash
+#  vim:ts=4:sts=4:sw=4:et
+#
+#  Author: Hari Sekhon
+#  Date: 2019-07-28 14:46:37 +0100 (Sun, 28 Jul 2019)
+#
+#  https://github.com/harisekhon/bash-tools
+#
+#  License: see accompanying Hari Sekhon LICENSE file
+#
+#  If you're using my code you're welcome to connect with me on LinkedIn and optionally send me feedback to help steer this or other code I publish
+#
+#  https://www.linkedin.com/in/harisekhon
+#
+
+export PATH="$PATH:/usr/hdp/current/kafka-broker/bin"
+
+# HDP defaults to 8GB, on VMs that often breaks cli commands which try to claim too much ram and fail
+export KAFKA_OPTS="$KAFKA_OPTS -Xms1G -Xmx1G"
+
+# there was another setting like KAFKA_KERBEROS_CLIENT I've used before but can't remember, this should work too
+export KAFKA_OPTS="$KAFKA_OPTS -Djava.security.auth.login.config=$srcdir/.bash.d/kafka_cli_jaas.conf"
+
+# Must use FQDNs to match Kerberos service principals
+#
+# Apache / Cloudera
+#export KAFKA_BROKERS="$(hostname -f):9092"
+#
+# Hortonworks
+#export KAFKA_BROKERS="$(hostname -f):6667"
+#
+#export KAFKA_ZOOKEEPERS="$(hostname -f):2181"
+
+#export KAFKA_ZOOKEEPER_ROOT=/kafka
+
+bootstrap_server=""
+if [ -n "${KAFKA_BROKERS:-}" ]; then
+    bootstrap_server="--bootstrap-server $KAFKA_BROKERS"
+fi
+
+broker_list=""
+if [ -n "${KAFKA_BROKERS:-}" ]; then
+    broker_list="--broker-list $KAFKA_BROKERS"
+fi
+
+kafka_zookeepers=""
+if [ -n "${KAFKA_BROKERS:-}" ]; then
+    kafka_zookeepers="--zookeepers $KAFKA_ZOOKEEPERS"
+fi
+