2 files changed, 41 insertions, 0 deletions
diff --git a/docker/kafka/Dockerfile.j2 b/docker/kafka/Dockerfile.j2
new file mode 100644
index 000000000..905444c70
--- /dev/null
+++ b/docker/kafka/Dockerfile.j2
@@ -0,0 +1,32 @@
+FROM {{ namespace }}/{{ image_prefix }}base:{{ tag }}
+MAINTAINER {{ maintainer }}
+
+{% block kafka_header %}{% endblock %}
+
+{% import "macros.j2" as macros with context %}
+
+{% if base_distro in ['centos', 'oraclelinux', 'rhel'] %}
+
+RUN echo '{{ install_type }} not yet available for {{ base_distro }}' \
+    && /bin/false
+
+{% elif base_distro in ['ubuntu', 'debian'] %}
+    {% set kafka_packages = [
+        'default-jre',
+    ] %}
+{% endif %}
+
+{{ macros.install_packages(kafka_packages | customizable("packages")) }}
+
+COPY extend_start.sh /usr/local/bin/kolla_extend_start
+ADD kafka-archive /
+RUN ln -s kafka* kafka \
+    && useradd --user-group --home-dir /kafka kafka \
+    && chmod 755 /usr/local/bin/kolla_extend_start \
+    && usermod -a -G kolla kafka \
+    && chown -R kafka: /kafka
+
+{% block kafka_footer %}{% endblock %}
+{% block footer %}{% endblock %}
+
+USER kafka
diff --git a/docker/kafka/extend_start.sh b/docker/kafka/extend_start.sh
new file mode 100644
index 000000000..ee6d494d2
--- /dev/null
+++ b/docker/kafka/extend_start.sh
@@ -0,0 +1,9 @@
+#!/bin/bash
+
+# Create log directory, with appropriate permissions
+if [[ ! -d "/var/log/kolla/kafka" ]]; then
+    mkdir -p /var/log/kolla/kafka
+fi
+if [[ $(stat -c %a /var/log/kolla/kafka) != "755" ]]; then
+    chmod 755 /var/log/kolla/kafka
+fi