CVS commit: pkgsrc/devel/kafka

To: pkgsrc-changes%NetBSD.org@localhost
Subject: CVS commit: pkgsrc/devel/kafka
From: "Filip Hajny" <fhajny%netbsd.org@localhost>
Date: Tue, 28 Feb 2017 08:17:29 +0000

Module Name:    pkgsrc
Committed By:   fhajny
Date:           Tue Feb 28 08:17:28 UTC 2017

Added Files:
        pkgsrc/devel/kafka: DESCR Makefile PLIST distinfo
        pkgsrc/devel/kafka/files/smf: manifest.xml
        pkgsrc/devel/kafka/patches: patch-bin_connect-distributed.sh
            patch-bin_connect-standalone.sh patch-bin_kafka-run-class.sh
            patch-bin_kafka-server-start.sh patch-bin_kafka-server-stop.sh
            patch-config_server.properties

Log Message:
Import Kafka 0.10.2.0 as devel/kafka.

Kafka is used for building real-time data pipelines and streaming
apps. It is horizontally scalable, fault-tolerant, wicked fast,
and runs in production in thousands of companies.


To generate a diff of this commit:
cvs rdiff -u -r0 -r1.1 pkgsrc/devel/kafka/DESCR pkgsrc/devel/kafka/Makefile \
    pkgsrc/devel/kafka/PLIST pkgsrc/devel/kafka/distinfo
cvs rdiff -u -r0 -r1.1 pkgsrc/devel/kafka/files/smf/manifest.xml
cvs rdiff -u -r0 -r1.1 \
    pkgsrc/devel/kafka/patches/patch-bin_connect-distributed.sh \
    pkgsrc/devel/kafka/patches/patch-bin_connect-standalone.sh \
    pkgsrc/devel/kafka/patches/patch-bin_kafka-run-class.sh \
    pkgsrc/devel/kafka/patches/patch-bin_kafka-server-start.sh \
    pkgsrc/devel/kafka/patches/patch-bin_kafka-server-stop.sh \
    pkgsrc/devel/kafka/patches/patch-config_server.properties

Please note that diffs are not public domain; they are subject to the
copyright notices on the relevant files.

Added files:

Index: pkgsrc/devel/kafka/DESCR
diff -u /dev/null pkgsrc/devel/kafka/DESCR:1.1
--- /dev/null   Tue Feb 28 08:17:29 2017
+++ pkgsrc/devel/kafka/DESCR    Tue Feb 28 08:17:28 2017
@@ -0,0 +1,3 @@
+Kafka is used for building real-time data pipelines and streaming
+apps. It is horizontally scalable, fault-tolerant, wicked fast,
+and runs in production in thousands of companies.
Index: pkgsrc/devel/kafka/Makefile
diff -u /dev/null pkgsrc/devel/kafka/Makefile:1.1
--- /dev/null   Tue Feb 28 08:17:29 2017
+++ pkgsrc/devel/kafka/Makefile Tue Feb 28 08:17:28 2017
@@ -0,0 +1,79 @@
+# $NetBSD: Makefile,v 1.1 2017/02/28 08:17:28 fhajny Exp $
+
+DISTNAME=      kafka_${SCALA_VERSION}-0.10.2.0
+PKGNAME=       ${DISTNAME:S/_${SCALA_VERSION}//}
+CATEGORIES=    net
+MASTER_SITES=  ${MASTER_SITE_APACHE:=kafka/${PKGVERSION_NOREV}/}
+EXTRACT_SUFX=  .tgz
+
+MAINTAINER=    filip%joyent.com@localhost
+HOMEPAGE=      http://kafka.apache.org/
+COMMENT=       Distributed streaming platform
+LICENSE=       apache-2.0 AND cddl-1.0
+
+DEPENDS+=      zookeeper-[0-9]*:../../devel/zookeeper
+
+USE_JAVA2=     7
+USE_LANGUAGES= # none
+
+NO_BUILD=      yes
+
+SCALA_VERSION= 2.12
+
+REPLACE_SH+=   bin/connect-* bin/kafka-*
+
+FILES_SUBST+=  KAFKA_USER=${KAFKA_USER} KAFKA_GROUP=${KAFKA_GROUP}
+
+PKG_SYSCONFSUBDIR=     kafka
+
+.include "../../mk/bsd.prefs.mk"
+
+BUILD_DEFS+=   KAFKA_DATADIR KAFKA_LOGDIR KAFKA_USER KAFKA_GROUP VARBASE
+
+KAFKA_DATADIR?=        ${VARBASE}/db/kafka
+KAFKA_LOGDIR?= ${VARBASE}/log/kafka
+KAFKA_USER?=   kafka
+KAFKA_GROUP?=  kafka
+
+PKG_GROUPS+=           ${KAFKA_GROUP}
+PKG_USERS+=            ${KAFKA_USER}:${KAFKA_GROUP}
+PKG_GECOS.${KAFKA_USER}=Kafka service user
+PKG_HOME.${KAFKA_USER}=        ${KAFKA_DATADIR}
+
+OWN_DIRS_PERMS+=       ${KAFKA_DATADIR} ${KAFKA_USER} ${KAFKA_GROUP} 0755
+OWN_DIRS_PERMS+=       ${KAFKA_LOGDIR} ${KAFKA_USER} ${KAFKA_GROUP} 0755
+
+CONFIG_FILES=          consumer log4j producer server tools-log4j      \
+                       connect-console-sink connect-console-source     \
+                       connect-distributed connect-file-sink           \
+                       connect-file-source connect-log4j               \
+                       connect-standalone
+
+.for file in ${CONFIG_FILES}
+CONF_FILES+=           share/examples/kafka/${file}.properties         \
+                       ${PKG_SYSCONFDIR}/${file}.properties
+.endfor
+
+SUBST_CLASSES+=                path
+SUBST_STAGE.path=      pre-configure
+SUBST_MESSAGE.path=    Fixing default paths
+SUBST_FILES.path=      bin/kafka-run-class.sh bin/kafka-server-start.sh
+SUBST_FILES.path+=     config/server.properties
+SUBST_VARS.path=       KAFKA_DATADIR KAFKA_LOGDIR PKG_SYSCONFDIR PKG_JAVA_HOME
+
+INSTALLATION_DIRS+=    bin share/examples/kafka lib/java/kafka/libs
+
+do-install:
+       ${INSTALL_SCRIPT} ${WRKSRC}/bin/connect-*.sh                    \
+               ${DESTDIR}${PREFIX}/bin
+       ${INSTALL_SCRIPT} ${WRKSRC}/bin/kafka-*.sh                      \
+               ${DESTDIR}${PREFIX}/bin
+       ${INSTALL_DATA} ${WRKSRC}/libs/*.jar            \
+               ${DESTDIR}${PREFIX}/lib/java/kafka/libs
+.for file in ${CONFIG_FILES}
+       ${INSTALL_DATA} ${WRKSRC}/config/${file}.properties             \
+               ${DESTDIR}${PREFIX}/share/examples/kafka
+.endfor
+
+.include "../../mk/java-vm.mk"
+.include "../../mk/bsd.pkg.mk"
Index: pkgsrc/devel/kafka/PLIST
diff -u /dev/null pkgsrc/devel/kafka/PLIST:1.1
--- /dev/null   Tue Feb 28 08:17:29 2017
+++ pkgsrc/devel/kafka/PLIST    Tue Feb 28 08:17:28 2017
@@ -0,0 +1,102 @@
+@comment $NetBSD: PLIST,v 1.1 2017/02/28 08:17:28 fhajny Exp $
+bin/connect-distributed.sh
+bin/connect-standalone.sh
+bin/kafka-acls.sh
+bin/kafka-broker-api-versions.sh
+bin/kafka-configs.sh
+bin/kafka-console-consumer.sh
+bin/kafka-console-producer.sh
+bin/kafka-consumer-groups.sh
+bin/kafka-consumer-offset-checker.sh
+bin/kafka-consumer-perf-test.sh
+bin/kafka-mirror-maker.sh
+bin/kafka-preferred-replica-election.sh
+bin/kafka-producer-perf-test.sh
+bin/kafka-reassign-partitions.sh
+bin/kafka-replay-log-producer.sh
+bin/kafka-replica-verification.sh
+bin/kafka-run-class.sh
+bin/kafka-server-start.sh
+bin/kafka-server-stop.sh
+bin/kafka-simple-consumer-shell.sh
+bin/kafka-streams-application-reset.sh
+bin/kafka-topics.sh
+bin/kafka-verifiable-consumer.sh
+bin/kafka-verifiable-producer.sh
+lib/java/kafka/libs/aopalliance-repackaged-2.5.0-b05.jar
+lib/java/kafka/libs/argparse4j-0.7.0.jar
+lib/java/kafka/libs/connect-api-${PKGVERSION}.jar
+lib/java/kafka/libs/connect-file-${PKGVERSION}.jar
+lib/java/kafka/libs/connect-json-${PKGVERSION}.jar
+lib/java/kafka/libs/connect-runtime-${PKGVERSION}.jar
+lib/java/kafka/libs/connect-transforms-${PKGVERSION}.jar
+lib/java/kafka/libs/guava-18.0.jar
+lib/java/kafka/libs/hk2-api-2.5.0-b05.jar
+lib/java/kafka/libs/hk2-locator-2.5.0-b05.jar
+lib/java/kafka/libs/hk2-utils-2.5.0-b05.jar
+lib/java/kafka/libs/jackson-annotations-2.8.0.jar
+lib/java/kafka/libs/jackson-annotations-2.8.5.jar
+lib/java/kafka/libs/jackson-core-2.8.5.jar
+lib/java/kafka/libs/jackson-databind-2.8.5.jar
+lib/java/kafka/libs/jackson-jaxrs-base-2.8.5.jar
+lib/java/kafka/libs/jackson-jaxrs-json-provider-2.8.5.jar
+lib/java/kafka/libs/jackson-module-jaxb-annotations-2.8.5.jar
+lib/java/kafka/libs/javassist-3.20.0-GA.jar
+lib/java/kafka/libs/javax.annotation-api-1.2.jar
+lib/java/kafka/libs/javax.inject-1.jar
+lib/java/kafka/libs/javax.inject-2.5.0-b05.jar
+lib/java/kafka/libs/javax.servlet-api-3.1.0.jar
+lib/java/kafka/libs/javax.ws.rs-api-2.0.1.jar
+lib/java/kafka/libs/jersey-client-2.24.jar
+lib/java/kafka/libs/jersey-common-2.24.jar
+lib/java/kafka/libs/jersey-container-servlet-2.24.jar
+lib/java/kafka/libs/jersey-container-servlet-core-2.24.jar
+lib/java/kafka/libs/jersey-guava-2.24.jar
+lib/java/kafka/libs/jersey-media-jaxb-2.24.jar
+lib/java/kafka/libs/jersey-server-2.24.jar
+lib/java/kafka/libs/jetty-continuation-9.2.15.v20160210.jar
+lib/java/kafka/libs/jetty-http-9.2.15.v20160210.jar
+lib/java/kafka/libs/jetty-io-9.2.15.v20160210.jar
+lib/java/kafka/libs/jetty-security-9.2.15.v20160210.jar
+lib/java/kafka/libs/jetty-server-9.2.15.v20160210.jar
+lib/java/kafka/libs/jetty-servlet-9.2.15.v20160210.jar
+lib/java/kafka/libs/jetty-servlets-9.2.15.v20160210.jar
+lib/java/kafka/libs/jetty-util-9.2.15.v20160210.jar
+lib/java/kafka/libs/jopt-simple-5.0.3.jar
+lib/java/kafka/libs/kafka-clients-${PKGVERSION}.jar
+lib/java/kafka/libs/kafka-log4j-appender-${PKGVERSION}.jar
+lib/java/kafka/libs/kafka-streams-${PKGVERSION}.jar
+lib/java/kafka/libs/kafka-streams-examples-${PKGVERSION}.jar
+lib/java/kafka/libs/kafka-tools-${PKGVERSION}.jar
+lib/java/kafka/libs/kafka_2.12-${PKGVERSION}-javadoc.jar
+lib/java/kafka/libs/kafka_2.12-${PKGVERSION}-scaladoc.jar
+lib/java/kafka/libs/kafka_2.12-${PKGVERSION}-sources.jar
+lib/java/kafka/libs/kafka_2.12-${PKGVERSION}-test-sources.jar
+lib/java/kafka/libs/kafka_2.12-${PKGVERSION}-test.jar
+lib/java/kafka/libs/kafka_2.12-${PKGVERSION}.jar
+lib/java/kafka/libs/log4j-1.2.17.jar
+lib/java/kafka/libs/lz4-1.3.0.jar
+lib/java/kafka/libs/metrics-core-2.2.0.jar
+lib/java/kafka/libs/osgi-resource-locator-1.0.1.jar
+lib/java/kafka/libs/reflections-0.9.10.jar
+lib/java/kafka/libs/rocksdbjni-5.0.1.jar
+lib/java/kafka/libs/scala-library-2.12.1.jar
+lib/java/kafka/libs/scala-parser-combinators_2.12-1.0.4.jar
+lib/java/kafka/libs/slf4j-api-1.7.21.jar
+lib/java/kafka/libs/slf4j-log4j12-1.7.21.jar
+lib/java/kafka/libs/snappy-java-1.1.2.6.jar
+lib/java/kafka/libs/validation-api-1.1.0.Final.jar
+lib/java/kafka/libs/zkclient-0.10.jar
+lib/java/kafka/libs/zookeeper-3.4.9.jar
+share/examples/kafka/connect-console-sink.properties
+share/examples/kafka/connect-console-source.properties
+share/examples/kafka/connect-distributed.properties
+share/examples/kafka/connect-file-sink.properties
+share/examples/kafka/connect-file-source.properties
+share/examples/kafka/connect-log4j.properties
+share/examples/kafka/connect-standalone.properties
+share/examples/kafka/consumer.properties
+share/examples/kafka/log4j.properties
+share/examples/kafka/producer.properties
+share/examples/kafka/server.properties
+share/examples/kafka/tools-log4j.properties
Index: pkgsrc/devel/kafka/distinfo
diff -u /dev/null pkgsrc/devel/kafka/distinfo:1.1
--- /dev/null   Tue Feb 28 08:17:29 2017
+++ pkgsrc/devel/kafka/distinfo Tue Feb 28 08:17:28 2017
@@ -0,0 +1,12 @@
+$NetBSD: distinfo,v 1.1 2017/02/28 08:17:28 fhajny Exp $
+
+SHA1 (kafka_2.12-0.10.2.0.tgz) = 655a4b415b0913117ebff88888ea526a3c2a4a06
+RMD160 (kafka_2.12-0.10.2.0.tgz) = bbcb13b9e0b16af72efd4a76258d555c07b99d8f
+SHA512 (kafka_2.12-0.10.2.0.tgz) = 79115d105d68457e437fe539d5f61f404f0a04ca6096299367fc03a3f50f928b9858b6cbf41160ec303de6cdaba8320e12f1219faae467cd08a775c9ac004141
+Size (kafka_2.12-0.10.2.0.tgz) = 34021573 bytes
+SHA1 (patch-bin_connect-distributed.sh) = 49e679e9d9d355921054a3723c96e519af871173
+SHA1 (patch-bin_connect-standalone.sh) = 9c300a771dbf02f733edd2b8a8cdf9f62c9322b4
+SHA1 (patch-bin_kafka-run-class.sh) = 3c3202feb125a575346d91465824d9dc8bcfa6e8
+SHA1 (patch-bin_kafka-server-start.sh) = 2e93ef575af6738e4af5555b395a10092e6de933
+SHA1 (patch-bin_kafka-server-stop.sh) = 6121f1a519aff541d018f0e57946a872f4253fdf
+SHA1 (patch-config_server.properties) = 1bdb5bfded1325a3a5afe070dc3081f6b24185a8

Index: pkgsrc/devel/kafka/files/smf/manifest.xml
diff -u /dev/null pkgsrc/devel/kafka/files/smf/manifest.xml:1.1
--- /dev/null   Tue Feb 28 08:17:29 2017
+++ pkgsrc/devel/kafka/files/smf/manifest.xml   Tue Feb 28 08:17:28 2017
@@ -0,0 +1,35 @@
+<?xml version="1.0"?>
+<!DOCTYPE service_bundle SYSTEM "/usr/share/lib/xml/dtd/service_bundle.dtd.1">
+<service_bundle type="manifest" name="kafka">
+  <service name="@SMF_PREFIX@/kafka" type="service" version="1">
+    <create_default_instance enabled="false" />
+    <single_instance />
+    <dependency name="network" grouping="require_all" restart_on="error" type="service">
+      <service_fmri value="svc:/milestone/network:default" />
+    </dependency>
+    <dependency name="filesystem" grouping="require_all" restart_on="error" type="service">
+      <service_fmri value="svc:/system/filesystem/local" />
+    </dependency>
+    <dependency name='kafka-zookeeper' grouping='require_all' restart_on='none' type='service'>
+      <service_fmri value='svc:/@SMF_PREFIX@/zookeeper' />
+    </dependency>
+    <method_context>
+      <method_credential user="@KAFKA_USER@" group="@KAFKA_GROUP@" />
+    </method_context>
+    <exec_method type="method" name="start" exec="@PREFIX@/bin/kafka-server-start.sh -daemon %{config_file}" timeout_seconds="60" />
+    <exec_method type="method" name="stop" exec=":kill" timeout_seconds="60" />
+    <property_group name="startd" type="framework">
+      <propval name="duration" type="astring" value="contract" />
+      <propval name="ignore_error" type="astring" value="core,signal" />
+    </property_group>
+    <property_group name="application" type="application">
+      <propval name="config_file" type="astring" value="@PKG_SYSCONFDIR@/server.properties" />
+    </property_group>
+    <stability value="Evolving" />
+    <template>
+      <common_name>
+        <loctext xml:lang="C">Kafka broker service</loctext>
+      </common_name>
+    </template>
+  </service>
+</service_bundle>

Index: pkgsrc/devel/kafka/patches/patch-bin_connect-distributed.sh
diff -u /dev/null pkgsrc/devel/kafka/patches/patch-bin_connect-distributed.sh:1.1
--- /dev/null   Tue Feb 28 08:17:29 2017
+++ pkgsrc/devel/kafka/patches/patch-bin_connect-distributed.sh Tue Feb 28 08:17:28 2017
@@ -0,0 +1,15 @@
+$NetBSD: patch-bin_connect-distributed.sh,v 1.1 2017/02/28 08:17:28 fhajny Exp $
+
+Paths.
+
+--- bin/connect-distributed.sh.orig    2017-02-14 17:26:08.000000000 +0000
++++ bin/connect-distributed.sh
+@@ -23,7 +23,7 @@ fi
+ base_dir=$(dirname $0)
+ 
+ if [ "x$KAFKA_LOG4J_OPTS" = "x" ]; then
+-    export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:$base_dir/../config/connect-log4j.properties"
++    export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:@PKG_SYSCONFDIR@/connect-log4j.properties"
+ fi
+ 
+ EXTRA_ARGS=${EXTRA_ARGS-'-name connectDistributed'}
Index: pkgsrc/devel/kafka/patches/patch-bin_connect-standalone.sh
diff -u /dev/null pkgsrc/devel/kafka/patches/patch-bin_connect-standalone.sh:1.1
--- /dev/null   Tue Feb 28 08:17:29 2017
+++ pkgsrc/devel/kafka/patches/patch-bin_connect-standalone.sh  Tue Feb 28 08:17:28 2017
@@ -0,0 +1,15 @@
+$NetBSD: patch-bin_connect-standalone.sh,v 1.1 2017/02/28 08:17:28 fhajny Exp $
+
+Paths.
+
+--- bin/connect-standalone.sh.orig     2017-02-14 17:26:08.000000000 +0000
++++ bin/connect-standalone.sh
+@@ -23,7 +23,7 @@ fi
+ base_dir=$(dirname $0)
+ 
+ if [ "x$KAFKA_LOG4J_OPTS" = "x" ]; then
+-    export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:$base_dir/../config/connect-log4j.properties"
++    export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:@PKG_SYSCONFDIR@/connect-log4j.properties"
+ fi
+ 
+ EXTRA_ARGS=${EXTRA_ARGS-'-name connectStandalone'}
Index: pkgsrc/devel/kafka/patches/patch-bin_kafka-run-class.sh
diff -u /dev/null pkgsrc/devel/kafka/patches/patch-bin_kafka-run-class.sh:1.1
--- /dev/null   Tue Feb 28 08:17:29 2017
+++ pkgsrc/devel/kafka/patches/patch-bin_kafka-run-class.sh     Tue Feb 28 08:17:28 2017
@@ -0,0 +1,119 @@
+$NetBSD: patch-bin_kafka-run-class.sh,v 1.1 2017/02/28 08:17:28 fhajny Exp $
+
+Paths.
+
+--- bin/kafka-run-class.sh.orig        2017-02-14 17:26:07.000000000 +0000
++++ bin/kafka-run-class.sh
+@@ -47,6 +47,10 @@ should_include_file() {
+ 
+ base_dir=$(dirname $0)/..
+ 
++if [ "x$JAVA_HOME" = "x" ]; then
++  JAVA_HOME=@PKG_JAVA_HOME@
++fi
++
+ if [ -z "$SCALA_VERSION" ]; then
+   SCALA_VERSION=2.10.6
+ fi
+@@ -55,84 +59,7 @@ if [ -z "$SCALA_BINARY_VERSION" ]; then
+   SCALA_BINARY_VERSION=$(echo $SCALA_VERSION | cut -f 1-2 -d '.')
+ fi
+ 
+-# run ./gradlew copyDependantLibs to get all dependant jars in a local dir
+-shopt -s nullglob
+-for dir in "$base_dir"/core/build/dependant-libs-${SCALA_VERSION}*;
+-do
+-  if [ -z "$CLASSPATH" ] ; then
+-    CLASSPATH="$dir/*"
+-  else
+-    CLASSPATH="$CLASSPATH:$dir/*"
+-  fi
+-done
+-
+-for file in "$base_dir"/examples/build/libs/kafka-examples*.jar;
+-do
+-  if should_include_file "$file"; then
+-    CLASSPATH="$CLASSPATH":"$file"
+-  fi
+-done
+-
+-for file in "$base_dir"/clients/build/libs/kafka-clients*.jar;
+-do
+-  if should_include_file "$file"; then
+-    CLASSPATH="$CLASSPATH":"$file"
+-  fi
+-done
+-
+-for file in "$base_dir"/streams/build/libs/kafka-streams*.jar;
+-do
+-  if should_include_file "$file"; then
+-    CLASSPATH="$CLASSPATH":"$file"
+-  fi
+-done
+-
+-for file in "$base_dir"/streams/examples/build/libs/kafka-streams-examples*.jar;
+-do
+-  if should_include_file "$file"; then
+-    CLASSPATH="$CLASSPATH":"$file"
+-  fi
+-done
+-
+-for file in "$base_dir"/streams/build/dependant-libs-${SCALA_VERSION}/rocksdb*.jar;
+-do
+-  CLASSPATH="$CLASSPATH":"$file"
+-done
+-
+-for file in "$base_dir"/tools/build/libs/kafka-tools*.jar;
+-do
+-  if should_include_file "$file"; then
+-    CLASSPATH="$CLASSPATH":"$file"
+-  fi
+-done
+-
+-for dir in "$base_dir"/tools/build/dependant-libs-${SCALA_VERSION}*;
+-do
+-  CLASSPATH="$CLASSPATH:$dir/*"
+-done
+-
+-for cc_pkg in "api" "transforms" "runtime" "file" "json" "tools"
+-do
+-  for file in "$base_dir"/connect/${cc_pkg}/build/libs/connect-${cc_pkg}*.jar;
+-  do
+-    if should_include_file "$file"; then
+-      CLASSPATH="$CLASSPATH":"$file"
+-    fi
+-  done
+-  if [ -d "$base_dir/connect/${cc_pkg}/build/dependant-libs" ] ; then
+-    CLASSPATH="$CLASSPATH:$base_dir/connect/${cc_pkg}/build/dependant-libs/*"
+-  fi
+-done
+-
+-# classpath addition for release
+-for file in "$base_dir"/libs/*;
+-do
+-  if should_include_file "$file"; then
+-    CLASSPATH="$CLASSPATH":"$file"
+-  fi
+-done
+-
+-for file in "$base_dir"/core/build/libs/kafka_${SCALA_BINARY_VERSION}*.jar;
++for file in $base_dir/lib/java/kafka/libs/*.jar;
+ do
+   if should_include_file "$file"; then
+     CLASSPATH="$CLASSPATH":"$file"
+@@ -152,13 +79,13 @@ fi
+ 
+ # Log directory to use
+ if [ "x$LOG_DIR" = "x" ]; then
+-  LOG_DIR="$base_dir/logs"
++  LOG_DIR="@KAFKA_LOGDIR@"
+ fi
+ 
+ # Log4j settings
+ if [ -z "$KAFKA_LOG4J_OPTS" ]; then
+   # Log to console. This is a tool.
+-  LOG4J_DIR="$base_dir/config/tools-log4j.properties"
++  LOG4J_DIR="@PKG_SYSCONFDIR@/tools-log4j.properties"
+   # If Cygwin is detected, LOG4J_DIR is converted to Windows format.
+   (( CYGWIN )) && LOG4J_DIR=$(cygpath --path --mixed "${LOG4J_DIR}")
+   KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:${LOG4J_DIR}"
Index: pkgsrc/devel/kafka/patches/patch-bin_kafka-server-start.sh
diff -u /dev/null pkgsrc/devel/kafka/patches/patch-bin_kafka-server-start.sh:1.1
--- /dev/null   Tue Feb 28 08:17:29 2017
+++ pkgsrc/devel/kafka/patches/patch-bin_kafka-server-start.sh  Tue Feb 28 08:17:28 2017
@@ -0,0 +1,15 @@
+$NetBSD: patch-bin_kafka-server-start.sh,v 1.1 2017/02/28 08:17:28 fhajny Exp $
+
+Paths.
+
+--- bin/kafka-server-start.sh.orig     2015-02-26 22:12:05.000000000 +0000
++++ bin/kafka-server-start.sh
+@@ -22,7 +22,7 @@ fi
+ base_dir=$(dirname $0)
+ 
+ if [ "x$KAFKA_LOG4J_OPTS" = "x" ]; then
+-    export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:$base_dir/../config/log4j.properties"
++    export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:@PKG_SYSCONFDIR@/log4j.properties"
+ fi
+ 
+ if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
Index: pkgsrc/devel/kafka/patches/patch-bin_kafka-server-stop.sh
diff -u /dev/null pkgsrc/devel/kafka/patches/patch-bin_kafka-server-stop.sh:1.1
--- /dev/null   Tue Feb 28 08:17:29 2017
+++ pkgsrc/devel/kafka/patches/patch-bin_kafka-server-stop.sh   Tue Feb 28 08:17:28 2017
@@ -0,0 +1,15 @@
+$NetBSD: patch-bin_kafka-server-stop.sh,v 1.1 2017/02/28 08:17:28 fhajny Exp $
+
+More columns to make grep match.
+
+--- bin/kafka-server-stop.sh.orig      2017-02-14 17:26:07.000000000 +0000
++++ bin/kafka-server-stop.sh
+@@ -13,7 +13,7 @@
+ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ # See the License for the specific language governing permissions and
+ # limitations under the License.
+-PIDS=$(ps ax | grep -i 'kafka\.Kafka' | grep java | grep -v grep | awk '{print $1}')
++PIDS=$(ps axwww | grep -i 'kafka\.Kafka' | grep java | grep -v grep | awk '{print $1}')
+ 
+ if [ -z "$PIDS" ]; then
+   echo "No kafka server to stop"
Index: pkgsrc/devel/kafka/patches/patch-config_server.properties
diff -u /dev/null pkgsrc/devel/kafka/patches/patch-config_server.properties:1.1
--- /dev/null   Tue Feb 28 08:17:29 2017
+++ pkgsrc/devel/kafka/patches/patch-config_server.properties   Tue Feb 28 08:17:28 2017
@@ -0,0 +1,15 @@
+$NetBSD: patch-config_server.properties,v 1.1 2017/02/28 08:17:28 fhajny Exp $
+
+Paths.
+
+--- config/server.properties.orig      2015-02-26 22:12:06.000000000 +0000
++++ config/server.properties
+@@ -55,7 +55,7 @@ socket.request.max.bytes=104857600
+ ############################# Log Basics #############################
+ 
+ # A comma seperated list of directories under which to store log files
+-log.dirs=/tmp/kafka-logs
++log.dirs=@KAFKA_DATADIR@
+ 
+ # The default number of log partitions per topic. More partitions allow greater
+ # parallelism for consumption, but this will also result in more files across

Prev by Date: CVS commit: pkgsrc/doc
Next by Date: CVS commit: pkgsrc/devel
Previous by Thread: CVS commit: pkgsrc/doc
Next by Thread: CVS commit: pkgsrc/devel
Indexes:

Home | Main Index | Thread Index | Old Index