Hi,
I have a simple test where I create a topology builder with one topic, one
processor using a persistent store, then I create a kafka streams, start
it, wait a bit, then close. Each time, the jvm crashes (seg fault) when
flushing the data. Anyone has already met this kind of problem ?
OS:
Ubuntu 16.04
JVM:
openjdk version "1.8.0_91"
OpenJDK Runtime Environment (build 1.8.0_91-8u91-b14-3ubuntu1~16.04.1-b14)
OpenJDK 64-Bit Server VM (build 25.91-b14, mixed mode)
Kafka:
kafka_2.11-0.10.0.1
The java code to reproduce the problem:
public static void main(String[] args) throws InterruptedException {
Map<String, Object> configs = new HashMap<>();
configs.put(StreamsConfig.ZOOKEEPER_CONNECT_CONFIG,
"localhost:2181");
configs.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG,
"localhost:9092");
configs.put(StreamsConfig.APPLICATION_ID_CONFIG, "test");
configs.put(StreamsConfig.KEY_SERDE_CLASS_CONFIG,
StringSerde.class.getName());
configs.put(StreamsConfig.VALUE_SERDE_CLASS_CONFIG,
StringSerde.class.getName());
TopologyBuilder builder = new TopologyBuilder()
.addSource("source", "test")
.addProcessor("processor", () -> new Processor<String,
String>() {
private KeyValueStore<String, String> kvStore;
public void init(ProcessorContext context) {
kvStore = (KeyValueStore<String, String>)
context.getStateStore("store");
}
public void process(String key, String value) {
}
public void close() {
kvStore.close();
}
@Override
public void punctuate(long timestamp) {
}
}, "source")
.addStateStore(Stores.create("store").withKeys(new
StringSerde()).withValues(new StringSerde()).persistent().build(),
"processor");
KafkaStreams streams = new KafkaStreams(builder, new
StreamsConfig(configs));
streams.start();
TimeUnit.SECONDS.sleep(20);
streams.close();
}
There is the log:
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.streams.StreamsConfig:178] StreamsConfig values:
replication.factor = 1
num.standby.replicas = 0
metric.reporters = []
commit.interval.ms = 30000
bootstrap.servers = [localhost:9092]
state.dir = /tmp/kafka-streams
partition.grouper = class
org.apache.kafka.streams.processor.DefaultPartitionGrouper
state.cleanup.delay.ms = 60000
poll.ms = 100
zookeeper.connect = localhost:2181
key.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde
metrics.sample.window.ms = 30000
buffered.records.per.partition = 1000
value.serde = class org.apache.kafka.common.serialization.Serdes$StringSerde
timestamp.extractor = class
org.apache.kafka.streams.processor.ConsumerRecordTimestampExtractor
num.stream.threads = 1
metrics.num.samples = 2
application.id = test
client.id =
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.streams.processor.internals.StreamThread:170] Creating
producer client for stream thread [StreamThread-1]
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.clients.producer.ProducerConfig:178] ProducerConfig
values:
metric.reporters = []
metadata.max.age.ms = 300000
reconnect.backoff.ms = 50
sasl.kerberos.ticket.renew.window.factor = 0.8
bootstrap.servers = [localhost:9092]
ssl.keystore.type = JKS
sasl.mechanism = GSSAPI
max.block.ms = 60000
interceptor.classes = null
ssl.truststore.password = null
client.id = test-1-StreamThread-1-producer
ssl.endpoint.identification.algorithm = null
request.timeout.ms = 30000
acks = 1
receive.buffer.bytes = 32768
ssl.truststore.type = JKS
retries = 0
ssl.truststore.location = null
ssl.keystore.password = null
send.buffer.bytes = 131072
compression.type = none
metadata.fetch.timeout.ms = 60000
retry.backoff.ms = 100
sasl.kerberos.kinit.cmd = /usr/bin/kinit
buffer.memory = 33554432
timeout.ms = 30000
key.serializer = class
org.apache.kafka.common.serialization.ByteArraySerializer
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
ssl.trustmanager.algorithm = PKIX
block.on.buffer.full = false
ssl.key.password = null
sasl.kerberos.min.time.before.relogin = 60000
connections.max.idle.ms = 540000
max.in.flight.requests.per.connection = 5
metrics.num.samples = 2
ssl.protocol = TLS
ssl.provider = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
batch.size = 16384
ssl.keystore.location = null
ssl.cipher.suites = null
security.protocol = PLAINTEXT
max.request.size = 1048576
value.serializer = class
org.apache.kafka.common.serialization.ByteArraySerializer
ssl.keymanager.algorithm = SunX509
metrics.sample.window.ms = 30000
partitioner.class = class
org.apache.kafka.clients.producer.internals.DefaultPartitioner
linger.ms = 100
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.clients.producer.ProducerConfig:178] ProducerConfig
values:
metric.reporters = []
metadata.max.age.ms = 300000
reconnect.backoff.ms = 50
sasl.kerberos.ticket.renew.window.factor = 0.8
bootstrap.servers = [localhost:9092]
ssl.keystore.type = JKS
sasl.mechanism = GSSAPI
max.block.ms = 60000
interceptor.classes = null
ssl.truststore.password = null
client.id = test-1-StreamThread-1-producer
ssl.endpoint.identification.algorithm = null
request.timeout.ms = 30000
acks = 1
receive.buffer.bytes = 32768
ssl.truststore.type = JKS
retries = 0
ssl.truststore.location = null
ssl.keystore.password = null
send.buffer.bytes = 131072
compression.type = none
metadata.fetch.timeout.ms = 60000
retry.backoff.ms = 100
sasl.kerberos.kinit.cmd = /usr/bin/kinit
buffer.memory = 33554432
timeout.ms = 30000
key.serializer = class
org.apache.kafka.common.serialization.ByteArraySerializer
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
ssl.trustmanager.algorithm = PKIX
block.on.buffer.full = false
ssl.key.password = null
sasl.kerberos.min.time.before.relogin = 60000
connections.max.idle.ms = 540000
max.in.flight.requests.per.connection = 5
metrics.num.samples = 2
ssl.protocol = TLS
ssl.provider = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
batch.size = 16384
ssl.keystore.location = null
ssl.cipher.suites = null
security.protocol = PLAINTEXT
max.request.size = 1048576
value.serializer = class
org.apache.kafka.common.serialization.ByteArraySerializer
ssl.keymanager.algorithm = SunX509
metrics.sample.window.ms = 30000
partitioner.class = class
org.apache.kafka.clients.producer.internals.DefaultPartitioner
linger.ms = 100
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.common.utils.AppInfoParser:83] Kafka version : 0.10.0.0
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.common.utils.AppInfoParser:84] Kafka commitId :
b8642491e78c5a13
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.streams.processor.internals.StreamThread:172] Creating
consumer client for stream thread [StreamThread-1]
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.clients.consumer.ConsumerConfig:178] ConsumerConfig
values:
metric.reporters = []
metadata.max.age.ms = 300000
partition.assignment.strategy =
[org.apache.kafka.streams.processor.internals.StreamPartitionAssignor]
reconnect.backoff.ms = 50
sasl.kerberos.ticket.renew.window.factor = 0.8
max.partition.fetch.bytes = 1048576
bootstrap.servers = [localhost:9092]
ssl.keystore.type = JKS
enable.auto.commit = false
sasl.mechanism = GSSAPI
interceptor.classes = null
exclude.internal.topics = true
ssl.truststore.password = null
client.id = test-1-StreamThread-1-consumer
ssl.endpoint.identification.algorithm = null
max.poll.records = 2147483647
check.crcs = true
request.timeout.ms = 40000
heartbeat.interval.ms = 3000
auto.commit.interval.ms = 5000
receive.buffer.bytes = 65536
ssl.truststore.type = JKS
ssl.truststore.location = null
ssl.keystore.password = null
fetch.min.bytes = 1
send.buffer.bytes = 131072
value.deserializer = class
org.apache.kafka.common.serialization.ByteArrayDeserializer
group.id = test
retry.backoff.ms = 100
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
ssl.trustmanager.algorithm = PKIX
ssl.key.password = null
fetch.max.wait.ms = 500
sasl.kerberos.min.time.before.relogin = 60000
connections.max.idle.ms = 540000
session.timeout.ms = 30000
metrics.num.samples = 2
key.deserializer = class
org.apache.kafka.common.serialization.ByteArrayDeserializer
ssl.protocol = TLS
ssl.provider = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.keystore.location = null
ssl.cipher.suites = null
security.protocol = PLAINTEXT
ssl.keymanager.algorithm = SunX509
metrics.sample.window.ms = 30000
auto.offset.reset = latest
11.10.2016 17:27:11 [ZkClient-EventThread-12-localhost:2181] INFO
[org.I0Itec.zkclient.ZkEventThread:64] Starting ZkClient event thread.
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client environment:zookeeper.version=3.4.6-1569965, built on 02/20/2014
09:09 GMT
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client environment:host.name=frank
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client environment:java.version=1.8.0_91
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client environment:java.vendor=Oracle Corporation
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client environment:java.home=/usr/lib/jvm/java-8-openjdk-amd64/jre
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client
environment:java.class.path=/home/pcoquentin/.gradle/caches/modules-2/files-2.1/javax.activation/activation/1.1.1/485de3a253e23f645037828c07f1d7f1af40763a/activation-1.1.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.google.code.findbugs/annotations/2.0.1/9ef6656259841cebfb9fb0697bb122ada4485498/annotations-2.0.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/aopalliance/aopalliance/1.0/235ba8b489512805ac13a8f9ea77a1ca5ebe3e8/aopalliance-1.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.mortbay.jasper/apache-el/8.0.9.M3/98daa71c32b7d27dd9463b36de9cebab3f2e5e2e/apache-el-8.0.9.M3.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.mortbay.jasper/apache-jsp/8.0.9.M3/e46309f2423c0d7321cc2a0928f4e411b82aee9/apache-jsp-8.0.9.M3.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/apache-jsp/9.2.10.v20150310/c56013c82395d3f053b338fee886008c29e07534/apache-jsp-9.2.10.v20150310.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.avro/avro/1.8.1/f4e11d00055760dca33daab193192bd75cc87b59/avro-1.8.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/cglib/cglib/2.2.2/a47a971686474124562bdd4a7ccbd8ac8c3e8b11/cglib-2.2.2.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/cglib/cglib-nodep/2.1_3/58d3be5953547c0019e5704d6ed4ffda3b0c7c66/cglib-nodep-2.1_3.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.fasterxml/classmate/1.0.0/434efef28c81162b17c540e634cffa3bd9b09b4c/classmate-1.0.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/commons-beanutils/commons-beanutils/1.8.3/686ef3410bcf4ab8ce7fd0b899e832aaba5facf7/commons-beanutils-1.8.3.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/commons-codec/commons-codec/1.8/af3be3f74d25fc5163b54f56a0d394b462dafafd/commons-codec-1.8.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/commons-collections/commons-collections/3.2.1/761ea405b9b37ced573d2df0d1e3a4e0f9edc668/commons-collections-3.2.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-compress/1.8.1/a698750c16740fd5b3871425f4cb3bbaa87f529d/commons-compress-1.8.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/commons-digester/commons-digester/1.8/dc6a73fdbd1fa3f0944e8497c6c872fa21dca37e/commons-digester-1.8.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-email/1.3.1/c8532fac118c53d65e302d45c23403f39b7ef7a9/commons-email-1.3.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-exec/1.1/7dfdf16fade726000564386825ed6d911a44ba1/commons-exec-1.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/commons-io/commons-io/2.4/b1b6ea3b7e4aa4f492509a4952029cd8e48019ad/commons-io-2.4.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/commons-lang/commons-lang/2.4/16313e02a793435009f1e458fa4af5d879f6fb11/commons-lang-2.4.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.commons/commons-lang3/3.3/5ccde9cb5e3071eaadf5d87a84b4d0aba43b119/commons-lang3-3.3.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/commons-logging/commons-logging/1.1.3/f6f66e966c70a83ffbdb6f17a0919eaf7c8aca7f/commons-logging-1.1.3.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/commons-validator/commons-validator/1.4.0/42fa1046955ade59f5354a1876cfc523cea33815/commons-validator-1.4.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.kafka/connect-api/
0.10.0.0/9dccf4be1c5c820a4a0ca84d5d9e727ca8c6af81/connect-api-0.10.0.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.kafka/connect-json/0.10.0.0/e62d16e17554245a99825b659c142a6581671f3c/connect-json-0.10.0.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.lmax/disruptor/3.2.1/db375f499e32c3f06549e9addf8b1647123d6426/disruptor-3.2.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/dumbster/dumbster/1.6/7536b28ac35e591695a6f5adc21601dcc9154f55/dumbster-1.6.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.goldmansachs/gs-collections/5.0.0/a0de1abeb508fdc29d1c07d4511cfba2961e5cf8/gs-collections-5.0.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.goldmansachs/gs-collections-api/5.0.0/674425dd8496f8bfb2b6ccc49feb36807c817f37/gs-collections-api-5.0.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.google.code.gson/gson/2.3/5fc52c41ef0239d1093a1eb7c3697036183677ce/gson-2.3.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.google.guava/guava/18.0/cce0823396aa693798f8882e64213b1772032b09/guava-18.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.hamcrest/hamcrest-core/1.3/42a25dc3219429f0e5d060061f71acb49bf010a0/hamcrest-core-1.3.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.hazelcast/hazelcast/2.6.10/2d687b3f030a432d818ab00e8d8274900cd5d4ea/hazelcast-2.6.10.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.hibernate/hibernate-validator/5.1.1.Final/2bd44618dc13c2be39231776a0edf0e1f867dedc/hibernate-validator-5.1.1.Final.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/net.sourceforge.htmlcleaner/htmlcleaner/2.13/3758f631eb305558d76baf78e555a5fce35af91d/htmlcleaner-2.13.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpclient/4.3.4/a9a1fef2faefed639ee0d0fba5b3b8e4eb2ff2d8/httpclient-4.3.4.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.httpcomponents/httpcore/4.3.2/31fbbff1ddbf98f3aa7377c94d33b0447c646b6e/httpcore-4.3.2.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.ibm.icu/icu4j/51_1/8ce396c4aed83c0c3de9158dc72c834fd283d5a4/icu4j-51_1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.ibm.icu/icu4j-charset/51_1/6d773f9c701a4388ba2e2a55833f843d32173b4c/icu4j-charset-51_1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.core/jackson-annotations/2.6.0/a0990e2e812ac6639b6ce955c91b13228500476e/jackson-annotations-2.6.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.core/jackson-core/2.6.3/142ce64dcd709a4b5f6e7d71305a31d3893d077/jackson-core-2.6.3.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-core-asl/1.9.13/3c304d70f42f832e0a86d45bd437f692129299a4/jackson-core-asl-1.9.13.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.fasterxml.jackson.core/jackson-databind/2.6.3/5c4fcae53dd82e2c549b8322d78c6ff47c94c8a8/jackson-databind-2.6.3.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-mapper-asl/1.9.13/1ee2f2bed0e5dd29d1cb155a166e6f8d50bbddb7/jackson-mapper-asl-1.9.13.jar:/home/pcoquentin/dev/git/sigfox-cloud/kafka-core/build/eclipse:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.javassist/javassist/3.19.0-GA/50120f69224dd8684b445a6f3a5b08fe9b5c60f6/javassist-3.19.0-GA.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/javax.servlet/javax.servlet-api/3.1.0/3cd63d075497751784b2fa84be59432f4905bf7c/javax.servlet-api-3.1.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/javax.servlet.jsp/javax.servlet.jsp-api/2.3.1/95c630902565feda8155eb32d46064ef348435fc/javax.servlet.jsp-api-2.3.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/javax.servlet.jsp.jstl/javax.servlet.jsp.jstl-api/1.2.1/f072f63ab1689e885ac40c221df3e6bb3e64a84a/javax.servlet.jsp.jstl-api-1.2.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/javax.websocket/javax.websocket-api/1.0/fc843b649d4a1dcb0497669d262befa3918c7ba8/javax.websocket-api-1.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.jboss.logging/jboss-logging/3.1.3.GA/64499e907f19e5e1b3fdc02f81440c1832fe3545/jboss-logging-3.1.3.GA.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.jdom/jdom2/2.0.5/2001db51c131e555bafdb77fc52af6a9408c505e/jdom2-2.0.5.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty.aggregate/jetty-all/9.2.10.v20150310/edfa6533fe43165a9c2e40bea484d8a0fd8dddf4/jetty-all-9.2.10.v20150310.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-http/9.2.10.v20150310/886b628f62cd518bbb04b37bd1b308fa19340a53/jetty-http-9.2.10.v20150310.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-io/9.2.10.v20150310/29bc6a5e2049d9858bfa811f2728a7a8efcdc1c0/jetty-io-9.2.10.v20150310.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty.toolchain/jetty-schemas/3.1.M0/6179bafb6ed2eb029862356df6713078c7874f85/jetty-schemas-3.1.M0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-server/9.2.10.v20150310/e6b8bff28b3e9ca6254415d2aa49603a5887fe8/jetty-server-9.2.10.v20150310.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty/jetty-util/9.2.10.v20150310/90cc75668dc9a9885108733d4d46420907cf863c/jetty-util-9.2.10.v20150310.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/jline/jline/0.9.94/99a18e9a44834afdebc467294e1138364c207402/jline-0.9.94.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/net.java.dev.jna/jna/3.4.0/803ff252fedbd395baffd43b37341dc4a150a554/jna-3.4.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/joda-time/joda-time/2.8.1/f5bfc718c95a7b1d3c371bb02a188a4df18361a9/joda-time-2.8.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/io.gatling/jsr166e/1.0/d1bf191a18dfe6e3157a4fbf6b527390d906ace6/jsr166e-1.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.google.code.findbugs/jsr305/2.0.1/516c03b21d50a644d538de0f0369c620989cd8f0/jsr305-2.0.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/junit/junit/3.8.1/99129f16442844f6a4a11ae22fbbee40b14d774f/junit-3.8.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/junit/junit/4.12/2973d150c0dc1fefe998f834810d68f278ea58ec/junit-4.12.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.jcraft/jzlib/1.1.2/a7d1993e6362271999be944b143352825cb5d966/jzlib-1.1.2.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.kafka/kafka-clients/0.10.0.0/6b18a4f31c796e5631343377c1c4f0e595131fb0/kafka-clients-0.10.0.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.kafka/kafka-streams/0.10.0.0/fe3678a6663b28abb75fb623c840d037161b3f32/kafka-streams-0.10.0.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.googlecode.libphonenumber/libphonenumber/5.6/d12dd73c6cd9919b39261121d6769a111638a6ab/libphonenumber-5.6.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/log4j/log4j/1.2.17/5af35056b4d257e4b64b9e8069c0746e8b08629f/log4j-1.2.17.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/net.jpountz.lz4/lz4/1.3.0/c708bb2590c0652a642236ef45d9f99ff842a2ce/lz4-1.3.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/javax.mail/mail/1.4.5/85319c87280f30e1afc54c355f91f44741beac49/mail-1.4.5.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.mockito/mockito-all/1.10.19/539df70269cc254a58cccc5d8e43286b4a73bf30/mockito-all-1.10.19.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.mongodb/mongo-java-driver/3.2.2/654b381c444d22e095363036767a52de1fda3ab0/mongo-java-driver-3.2.2.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/io.netty/netty/3.7.0.Final/7a8c35599c68c0bf383df74469aa3e03d9aca87/netty-3.7.0.Final.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/io.netty/netty-buffer/4.1.4.Final/5e199381c808377faeeb80e69f365246004d6f9f/netty-buffer-4.1.4.Final.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/io.netty/netty-codec/4.1.4.Final/86fc9367492cdca25542fb037467ab853a77ff62/netty-codec-4.1.4.Final.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/io.netty/netty-codec-http/4.1.4.Final/f6ef27ed46dd806dc27c1f0ed2e6bcfad12d28cc/netty-codec-http-4.1.4.Final.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/io.netty/netty-codec-http2/4.1.4.Final/1fa3a372fd2bce2a13379b909a8d4becbcd6b25a/netty-codec-http2-4.1.4.Final.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/io.netty/netty-common/4.1.4.Final/e267ca463a0dc6292cf5e0528c4b59d6d5f76ff5/netty-common-4.1.4.Final.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/io.netty/netty-handler/4.1.4.Final/5674b3bc1203d913da71ba98bb7d43832c7a71e7/netty-handler-4.1.4.Final.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/io.netty/netty-resolver/4.1.4.Final/19f86688069a018cf5e45f7a9f9a02971b9e31ee/netty-resolver-4.1.4.Final.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/io.netty/netty-transport/4.1.4.Final/6c99d2323d75d74b9571c4ddbdc411d96bf8d780/netty-transport-4.1.4.Final.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.objenesis/objenesis/2.1/87c0ea803b69252868d09308b4618f766f135a96/objenesis-2.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.eclipse.jetty.orbit/org.eclipse.jdt.core/3.8.2.v20130121/ebb04771ae21dec8682e4153e97404d9933a9c13/org.eclipse.jdt.core-3.8.2.v20130121.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.thoughtworks.paranamer/paranamer/2.7/3ed64c69e882a324a75e890024c32a28aff0ade8/paranamer-2.7.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/net.java.dev.jna/platform/3.4.0/e3f70017be8100d3d6923f50b3d2ee17714e9c13/platform-3.4.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-api-mockito/1.6.2/c213230ae20a7b422f3d622a261d0e3427d2464c/powermock-api-mockito-1.6.2.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-api-support/1.6.2/93b21413b4ee99b7bc0dd34e1416fdca96866aaf/powermock-api-support-1.6.2.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-core/1.6.2/ea04e79244e19dcf0c3ccf6863c5b028b4b58c9c/powermock-core-1.6.2.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-module-junit4/1.6.2/dff58978da716e000463bc1b08013d6a7cf3d696/powermock-module-junit4-1.6.2.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-module-junit4-common/1.6.2/48dd7406e11a14fe2ae4ab641e1f27510e896640/powermock-module-junit4-common-1.6.2.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.powermock/powermock-reflect/1.6.2/1af1bbd1207c3ecdcf64973e6f9d57dcd17cc145/powermock-reflect-1.6.2.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.projectreactor/reactor-core/1.1.3.RELEASE/f1e17a034d4eae0f0ba6a49bcdaf166ad012ae05/reactor-core-1.1.3.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.reflections/reflections/0.9.10/c7f4ea230aedc757ca1499ebcfb2953c81cf8b67/reflections-0.9.10.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.rocksdb/rocksdbjni/4.4.1/e3de3221387f21871d48376df851589d288d51ac/rocksdbjni-4.4.1.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.codeborne/selenide/2.16/5b9b8b10227ea87eceba16afd22dc49579fb55b7/selenide-2.16.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.seleniumhq.selenium/selenium-api/2.44.0/ed8379783481df59c8046f9671c0e0195acd930d/selenium-api-2.44.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.seleniumhq.selenium/selenium-chrome-driver/2.44.0/8322dfa839ec29ed7ba3397be3b9a49dda037d5/selenium-chrome-driver-2.44.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.seleniumhq.selenium/selenium-firefox-driver/2.44.0/123ed3b0b8b70e51f6794ba1b1531a199e307249/selenium-firefox-driver-2.44.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.seleniumhq.selenium/selenium-ie-driver/2.44.0/deee9750f5d20f7c78ad44a3c896bfbea613711a/selenium-ie-driver-2.44.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.seleniumhq.selenium/selenium-java/2.44.0/f98c321ba1e4ec81a016bcadbf49c80c29ebdc69/selenium-java-2.44.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.seleniumhq.selenium/selenium-remote-driver/2.44.0/ef7b79655dfab115b04dee1e2be22f2c3411c0e9/selenium-remote-driver-2.44.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.seleniumhq.selenium/selenium-safari-driver/2.44.0/c6e505c109c85022cee747eac07965cca78b6191/selenium-safari-driver-2.44.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.seleniumhq.selenium/selenium-support/2.44.0/42825651e29d1b850699233687a0767063bef153/selenium-support-2.44.0.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-api/1.7.21/139535a69a4239db087de9bab0bee568bf8e0b70/slf4j-api-1.7.21.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.21/7238b064d1aba20da2ac03217d700d91e02460fa/slf4j-log4j12-1.7.21.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.xerial.snappy/snappy-java/1.1.2.4/40370f7364a63c79d966074e19480ad1c998d1e2/snappy-java-1.1.2.4.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework/spring-aop/4.0.5.RELEASE/d22abbbba78f7c8854fc39346cc99362272c5c90/spring-aop-4.0.5.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework/spring-beans/4.0.5.RELEASE/11e00022f109653ee0dbe16b59c26e19bd90fa08/spring-beans-4.0.5.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework/spring-context/4.0.5.RELEASE/98cd9a4b8bb0c695c0cfcc204cf804f433851cfe/spring-context-4.0.5.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework/spring-context-support/4.0.5.RELEASE/bb6ddc22c49cb5bec1a756b0fbb138e2b705c508/spring-context-support-4.0.5.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework/spring-core/4.0.5.RELEASE/cce94116431b5a1384d58316a4090bbe7718fd5a/spring-core-4.0.5.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework/spring-expression/4.0.5.RELEASE/d7ddbc320c31c15cb3612ed64607e181c3b2d851/spring-expression-4.0.5.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework/spring-jdbc/3.2.8.RELEASE/8fc09a51ca267726ffd284ab4de7c02f667da2ad/spring-jdbc-3.2.8.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework.security/spring-security-acl/3.2.4.RELEASE/a015c944e8018fb337075ee7c74876133cee555f/spring-security-acl-3.2.4.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework.security/spring-security-core/3.2.4.RELEASE/493bc57396a821e8ffa7d99fac77cc79c15e9b7f/spring-security-core-3.2.4.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework.security/spring-security-web/3.2.4.RELEASE/197d803ab63dd3523d9df186505fc1cc93044334/spring-security-web-3.2.4.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework/spring-test/4.0.5.RELEASE/caa3ead3ab38ecaa979ec7054fdfc1b73d36f916/spring-test-4.0.5.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework/spring-tx/3.2.8.RELEASE/af44bdd6dd44557f6a03021a7d2721bbf1708ec1/spring-tx-3.2.8.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework/spring-web/4.0.5.RELEASE/1819f6d4ab65fb33e19c492d5c5aa21396e42b3f/spring-web-4.0.5.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.springframework/spring-webmvc/4.0.5.RELEASE/2459455b0f2e19e7a51fc7bff4de341947d9bc57/spring-webmvc-4.0.5.RELEASE.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.fusesource.wikitext/textile-core/1.3/92884d64ac3b825b52bbfee44d661b6cfae36b4c/textile-core-1.3.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.tomcat/tomcat-api/8.0.21/6575738ab8a56d6c0d3679ddd1959c6f03288386/tomcat-api-8.0.21.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.tomcat/tomcat-servlet-api/8.0.21/fed19191e861d66315d9ff00484ec92106c41644/tomcat-servlet-api-8.0.21.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/javax.validation/validation-api/1.1.0.Final/8613ae82954779d518631e05daa73a6a954817d5/validation-api-1.1.0.Final.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.velocity/velocity/1.7/2ceb567b8f3f21118ecdec129fe1271dbc09aa7a/velocity-1.7.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.webbitserver/webbit/0.4.14/3bf3f17fe41fb34c4d98663957ec0795a6b6653e/webbit-0.4.14.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.fusesource.wikitext/wikitext-core/1.3/cdbcab0ee1c2e456161f711751416cf2cbd39688/wikitext-core-1.3.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.tukaani/xz/1.5/9c64274b7dbb65288237216e3fae7877fd3f2bee/xz-1.5.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/com.101tec/zkclient/0.8/c0f700a4a3b386279d7d8dd164edecbe836cbfdb/zkclient-0.8.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.apache.zookeeper/zookeeper/3.4.6/1b2502e29da1ebaade2357cd1de35a855fa3755/zookeeper-3.4.6.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-core-asl/1.9.12/ecfc6f73a841c4c3c653b59651a3f9d5f1286469/jackson-core-asl-1.9.12.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.codehaus.jackson/jackson-mapper-asl/1.9.12/8b290aae44213e2f6da00c07af59b0d442068f4d/jackson-mapper-asl-1.9.12.jar:/home/pcoquentin/dev/git/sigfox-cloud/commons-utils/build/eclipse:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-api/1.7.7/2b8019b6249bb05d81d3a3094e468753e2b21311/slf4j-api-1.7.7.jar:/home/pcoquentin/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.2/7539c264413b9b1ff9841cd00058c974b7cd1ec9/slf4j-log4j12-1.7.2.jar
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client
environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client environment:java.io.tmpdir=/tmp
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client environment:java.compiler=<NA>
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client environment:os.name=Linux
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client environment:os.arch=amd64
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client environment:os.version=4.4.0-38-generic
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client environment:user.name=pcoquentin
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client environment:user.home=/home/pcoquentin
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:100]
Client environment:user.dir=/home/pcoquentin/dev/git/sigfox-cloud/kafka-core
11.10.2016 17:27:11 [main] INFO [org.apache.zookeeper.ZooKeeper:438]
Initiating client connection, connectString=localhost:2181
sessionTimeout=30000 watcher=org.I0Itec.zkclient.ZkClient@9660f4e
11.10.2016 17:27:11 [main] INFO [org.I0Itec.zkclient.ZkClient:935] Waiting
for keeper state SyncConnected
11.10.2016 17:27:11 [main-SendThread(localhost:2181)] INFO
[org.apache.zookeeper.ClientCnxn:975] Opening socket connection to server
localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL
(unknown error)
11.10.2016 17:27:11 [main-SendThread(localhost:2181)] INFO
[org.apache.zookeeper.ClientCnxn:852] Socket connection established to
localhost/127.0.0.1:2181, initiating session
11.10.2016 17:27:11 [main-SendThread(localhost:2181)] INFO
[org.apache.zookeeper.ClientCnxn:1235] Session establishment complete on
server localhost/127.0.0.1:2181, sessionid = 0x157b45a3c5d0004, negotiated
timeout = 30000
11.10.2016 17:27:11 [main-EventThread] INFO
[org.I0Itec.zkclient.ZkClient:712] zookeeper state changed (SyncConnected)
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.clients.consumer.ConsumerConfig:178] ConsumerConfig
values:
metric.reporters = []
metadata.max.age.ms = 300000
partition.assignment.strategy =
[org.apache.kafka.streams.processor.internals.StreamPartitionAssignor]
reconnect.backoff.ms = 50
sasl.kerberos.ticket.renew.window.factor = 0.8
max.partition.fetch.bytes = 1048576
bootstrap.servers = [localhost:9092]
ssl.keystore.type = JKS
enable.auto.commit = false
sasl.mechanism = GSSAPI
interceptor.classes = null
exclude.internal.topics = true
ssl.truststore.password = null
client.id = test-1-StreamThread-1-consumer
ssl.endpoint.identification.algorithm = null
max.poll.records = 2147483647
check.crcs = true
request.timeout.ms = 40000
heartbeat.interval.ms = 3000
auto.commit.interval.ms = 5000
receive.buffer.bytes = 65536
ssl.truststore.type = JKS
ssl.truststore.location = null
ssl.keystore.password = null
fetch.min.bytes = 1
send.buffer.bytes = 131072
value.deserializer = class
org.apache.kafka.common.serialization.ByteArrayDeserializer
group.id = test
retry.backoff.ms = 100
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
ssl.trustmanager.algorithm = PKIX
ssl.key.password = null
fetch.max.wait.ms = 500
sasl.kerberos.min.time.before.relogin = 60000
connections.max.idle.ms = 540000
session.timeout.ms = 30000
metrics.num.samples = 2
key.deserializer = class
org.apache.kafka.common.serialization.ByteArrayDeserializer
ssl.protocol = TLS
ssl.provider = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.keystore.location = null
ssl.cipher.suites = null
security.protocol = PLAINTEXT
ssl.keymanager.algorithm = SunX509
metrics.sample.window.ms = 30000
auto.offset.reset = latest
11.10.2016 17:27:11 [main] WARN
[org.apache.kafka.clients.consumer.ConsumerConfig:186] The configuration
replication.factor = 1 was supplied but isn't a known config.
11.10.2016 17:27:11 [main] WARN
[org.apache.kafka.clients.consumer.ConsumerConfig:186] The configuration
num.standby.replicas = 0 was supplied but isn't a known config.
11.10.2016 17:27:11 [main] WARN
[org.apache.kafka.clients.consumer.ConsumerConfig:186] The configuration
zookeeper.connect = localhost:2181 was supplied but isn't a known config.
11.10.2016 17:27:11 [main] WARN
[org.apache.kafka.clients.consumer.ConsumerConfig:186] The configuration
__stream.thread.instance__ = Thread[StreamThread-1,5,main] was supplied but
isn't a known config.
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.common.utils.AppInfoParser:83] Kafka version : 0.10.0.0
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.common.utils.AppInfoParser:84] Kafka commitId :
b8642491e78c5a13
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.streams.processor.internals.StreamThread:175] Creating
restore consumer client for stream thread [StreamThread-1]
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.clients.consumer.ConsumerConfig:178] ConsumerConfig
values:
metric.reporters = []
metadata.max.age.ms = 300000
partition.assignment.strategy =
[org.apache.kafka.clients.consumer.RangeAssignor]
reconnect.backoff.ms = 50
sasl.kerberos.ticket.renew.window.factor = 0.8
max.partition.fetch.bytes = 1048576
bootstrap.servers = [localhost:9092]
ssl.keystore.type = JKS
enable.auto.commit = false
sasl.mechanism = GSSAPI
interceptor.classes = null
exclude.internal.topics = true
ssl.truststore.password = null
client.id = test-1-StreamThread-1-restore-consumer
ssl.endpoint.identification.algorithm = null
max.poll.records = 2147483647
check.crcs = true
request.timeout.ms = 40000
heartbeat.interval.ms = 3000
auto.commit.interval.ms = 5000
receive.buffer.bytes = 65536
ssl.truststore.type = JKS
ssl.truststore.location = null
ssl.keystore.password = null
fetch.min.bytes = 1
send.buffer.bytes = 131072
value.deserializer = class
org.apache.kafka.common.serialization.ByteArrayDeserializer
group.id =
retry.backoff.ms = 100
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
ssl.trustmanager.algorithm = PKIX
ssl.key.password = null
fetch.max.wait.ms = 500
sasl.kerberos.min.time.before.relogin = 60000
connections.max.idle.ms = 540000
session.timeout.ms = 30000
metrics.num.samples = 2
key.deserializer = class
org.apache.kafka.common.serialization.ByteArrayDeserializer
ssl.protocol = TLS
ssl.provider = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.keystore.location = null
ssl.cipher.suites = null
security.protocol = PLAINTEXT
ssl.keymanager.algorithm = SunX509
metrics.sample.window.ms = 30000
auto.offset.reset = latest
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.clients.consumer.ConsumerConfig:178] ConsumerConfig
values:
metric.reporters = []
metadata.max.age.ms = 300000
partition.assignment.strategy =
[org.apache.kafka.clients.consumer.RangeAssignor]
reconnect.backoff.ms = 50
sasl.kerberos.ticket.renew.window.factor = 0.8
max.partition.fetch.bytes = 1048576
bootstrap.servers = [localhost:9092]
ssl.keystore.type = JKS
enable.auto.commit = false
sasl.mechanism = GSSAPI
interceptor.classes = null
exclude.internal.topics = true
ssl.truststore.password = null
client.id = test-1-StreamThread-1-restore-consumer
ssl.endpoint.identification.algorithm = null
max.poll.records = 2147483647
check.crcs = true
request.timeout.ms = 40000
heartbeat.interval.ms = 3000
auto.commit.interval.ms = 5000
receive.buffer.bytes = 65536
ssl.truststore.type = JKS
ssl.truststore.location = null
ssl.keystore.password = null
fetch.min.bytes = 1
send.buffer.bytes = 131072
value.deserializer = class
org.apache.kafka.common.serialization.ByteArrayDeserializer
group.id =
retry.backoff.ms = 100
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
ssl.trustmanager.algorithm = PKIX
ssl.key.password = null
fetch.max.wait.ms = 500
sasl.kerberos.min.time.before.relogin = 60000
connections.max.idle.ms = 540000
session.timeout.ms = 30000
metrics.num.samples = 2
key.deserializer = class
org.apache.kafka.common.serialization.ByteArrayDeserializer
ssl.protocol = TLS
ssl.provider = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.keystore.location = null
ssl.cipher.suites = null
security.protocol = PLAINTEXT
ssl.keymanager.algorithm = SunX509
metrics.sample.window.ms = 30000
auto.offset.reset = latest
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.common.utils.AppInfoParser:83] Kafka version : 0.10.0.0
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.common.utils.AppInfoParser:84] Kafka commitId :
b8642491e78c5a13
11.10.2016 17:27:11 [main] INFO
[org.apache.kafka.streams.KafkaStreams:172] Started Kafka Stream process
11.10.2016 17:27:11 [StreamThread-1] INFO
[org.apache.kafka.streams.processor.internals.StreamThread:215] Starting
stream thread [StreamThread-1]
11.10.2016 17:27:12 [StreamThread-1] INFO
[org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505]
Discovered coordinator frank:9092 (id: 2147483647 rack: null) for group
test.
11.10.2016 17:27:12 [StreamThread-1] INFO
[org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:280]
Revoking previously assigned partitions [] for group test
11.10.2016 17:27:12 [StreamThread-1] INFO
[org.apache.kafka.clients.consumer.internals.AbstractCoordinator:326]
(Re-)joining group test
11.10.2016 17:27:12 [StreamThread-1] INFO
[org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:197]
Completed validating internal topics in partition assignor.
11.10.2016 17:27:12 [StreamThread-1] INFO
[org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:197]
Completed validating internal topics in partition assignor.
11.10.2016 17:27:12 [StreamThread-1] INFO
[org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:197]
Completed validating internal topics in partition assignor.
11.10.2016 17:27:12 [StreamThread-1] INFO
[org.apache.kafka.clients.consumer.internals.AbstractCoordinator:434]
Successfully joined group test with generation 1
11.10.2016 17:27:12 [StreamThread-1] INFO
[org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:219]
Setting newly assigned partitions [test-1, test-0, test-3, test-2] for
group test
11.10.2016 17:27:12 [StreamThread-1] INFO
[org.apache.kafka.streams.processor.internals.StreamTask:109] Creating
restoration consumer client for stream task #0_0
11.10.2016 17:27:12 [StreamThread-1] INFO
[org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505]
Discovered coordinator frank:9092 (id: 2147483647 rack: null) for group .
11.10.2016 17:27:12 [StreamThread-1] INFO
[org.apache.kafka.streams.processor.internals.StreamTask:109] Creating
restoration consumer client for stream task #0_1
11.10.2016 17:27:13 [StreamThread-1] INFO
[org.apache.kafka.streams.processor.internals.StreamTask:109] Creating
restoration consumer client for stream task #0_2
11.10.2016 17:27:13 [StreamThread-1] INFO
[org.apache.kafka.streams.processor.internals.StreamTask:109] Creating
restoration consumer client for stream task #0_3
11.10.2016 17:27:31 [StreamThread-1] INFO
[org.apache.kafka.streams.processor.internals.StreamThread:244] Shutting
down stream thread [StreamThread-1]
11.10.2016 17:27:31 [StreamThread-1] INFO
[org.apache.kafka.clients.producer.KafkaProducer:658] Closing the Kafka
producer with timeoutMillis = 9223372036854775807 ms.
11.10.2016 17:27:32 [StreamThread-1] INFO
[org.apache.kafka.streams.processor.internals.StreamThread:606] Removing a
task 0_0
#
# A fatal error has been detected by the Java Runtime Environment:
#
# SIGSEGV (0xb) at pc=0x00007f157bb618e8, pid=20746, tid=139731402655488
#
# JRE version: OpenJDK Runtime Environment (8.0_91-b14) (build
1.8.0_91-8u91-b14-3ubuntu1~16.04.1-b14)
# Java VM: OpenJDK 64-Bit Server VM (25.91-b14 mixed mode linux-amd64
compressed oops)
# Problematic frame:
# C [librocksdbjni1469239172234563947..so+0x15b8e8]
Java_org_rocksdb_RocksDB_write0+0x48
#
# Core dump written. Default location:
/home/pcoquentin/dev/git/sigfox-cloud/kafka-core/core or core.20746
#
# An error report file with more information is saved as:
# /home/pcoquentin/dev/git/sigfox-cloud/kafka-core/hs_err_pid20746.log
#
# If you would like to submit a bug report, please visit:
# http://bugreport.java.com/bugreport/crash.jsp
# The crash happened outside the Java Virtual Machine in native code.
# See problematic frame for where to report the bug.
#
Finally, the stack trace of the crash :
C [librocksdbjni1469239172234563947..so+0x15b8e8]
Java_org_rocksdb_RocksDB_write0+0x48
j org.rocksdb.RocksDB.write0(JJ)V+0
j
org.rocksdb.RocksDB.write(Lorg/rocksdb/WriteOptions;Lorg/rocksdb/WriteBatch;)V+9
j
org.apache.kafka.streams.state.internals.RocksDBStore.putAllInternal(Ljava/util/List;)V+67
j org.apache.kafka.streams.state.internals.RocksDBStore.flushCache()V+163
j org.apache.kafka.streams.state.internals.RocksDBStore.flush()V+1
j org.apache.kafka.streams.state.internals.MeteredKeyValueStore.flush()V+14
j
org.apache.kafka.streams.processor.internals.ProcessorStateManager.close(Ljava/util/Map;)V+81
j org.apache.kafka.streams.processor.internals.AbstractTask.close()V+8
j org.apache.kafka.streams.processor.internals.StreamTask.close()V+94
j
org.apache.kafka.streams.processor.internals.StreamThread.closeOne(Lorg/apache/kafka/streams/processor/internals/AbstractTask;)V+15
j
org.apache.kafka.streams.processor.internals.StreamThread.removeStreamTasks()V+36
j org.apache.kafka.streams.processor.internals.StreamThread.shutdown()V+195
j org.apache.kafka.streams.processor.internals.StreamThread.run()V+40
Thanks for the help
Pierre
