Hi,
I already tried to store rocks db files somewhere else by specifying the
kafa state dir properties, but no luck, same behavior.
I will try to run with the trunk tomorrow to see if it's stop correctly,
and I will keep you inform. There must be something with my configuration,
because I googled and saw nothing about this problem.
On Tue, Oct 11, 2016 at 9:28 PM, Eno Thereska <eno.there...@gmail.com>
wrote:
> Hi Pierre,
>
> I tried the exact code on MacOs and am not getting any errors. Could you
> check if all the directories in /tmp where Kafka Streams writes the RocksDb
> files are empty? I'm wondering if there is some bad state left over.
>
> Finally looks like you are running 0.10.0, could you try running trunk to
> see if the problem still exists? I'm running trunk. I know there were a
> couple of RocksDb fixes after 0.10.0
>
> Thanks
> Eno
>
> > On 11 Oct 2016, at 16:41, Pierre Coquentin <pierre.coquen...@gmail.com>
> wrote:
> >
> > 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/9ef6656259841cebfb9fb0697bb122
> ada4485498/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/98daa71c32b7d27dd9463b36de9ceb
> ab3f2e5e2e/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/f4e11d00055760dca33daab193192b
> d75cc87b59/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/58d3be5953547c0019e5704d6ed4ff
> da3b0c7c66/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/686ef3410bcf4ab8ce7fd0b899e832
> aaba5facf7/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/dc6a73fdbd1fa3f0944e8497c6c872
> fa21dca37e/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/7dfdf16fade726000564386825ed6d
> 911a44ba1/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/16313e02a793435009f1e458fa4af5
> d879f6fb11/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/f6f66e966c70a83ffbdb6f17a0919e
> af7c8aca7f/commons-logging-1.1.3.jar:/home/pcoquentin/.
> gradle/caches/modules-2/files-2.1/commons-validator/commons-
> validator/1.4.0/42fa1046955ade59f5354a1876cfc5
> 23cea33815/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/e62d16e17554245a99825b659c142a
> 6581671f3c/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/7536b28ac35e591695a6f5adc21601
> dcc9154f55/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/5fc52c41ef0239d1093a1eb7c36970
> 36183677ce/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/42a25dc3219429f0e5d060061f71ac
> b49bf010a0/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/a9a1fef2faefed639ee0d0fba5b3b8
> e4eb2ff2d8/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/8ce396c4aed83c0c3de9158dc72c83
> 4fd283d5a4/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/3cd63d075497751784b2fa84be5943
> 2f4905bf7c/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/95c630902565feda8155eb32d46064
> ef348435fc/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/2001db51c131e555bafdb77fc52af6
> a9408c505e/jdom2-2.0.5.jar:/home/pcoquentin/.gradle/
> caches/modules-2/files-2.1/org.eclipse.jetty.aggregate/
> jetty-all/9.2.10.v20150310/edfa6533fe43165a9c2e40bea484d8
> a0fd8dddf4/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/29bc6a5e2049d9858bfa811f2728a7
> a8efcdc1c0/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/90cc75668dc9a9885108733d4d4642
> 0907cf863c/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/803ff252fedbd395baffd43b37341d
> c4a150a554/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/d1bf191a18dfe6e3157a4fbf6b5273
> 90d906ace6/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/6b18a4f31c796e5631343377c1c4f0
> e595131fb0/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/5af35056b4d257e4b64b9e8069c074
> 6e8b08629f/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/539df70269cc254a58cccc5d8e4328
> 6b4a73bf30/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/7a8c35599c68c0bf383df74469aa3e
> 03d9aca87/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/86fc9367492cdca25542fb037467ab
> 853a77ff62/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/5674b3bc1203d913da71ba98bb7d43
> 832c7a71e7/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/6c99d2323d75d74b9571c4ddbdc411
> d96bf8d780/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/e3f70017be8100d3d6923f50b3d2ee
> 17714e9c13/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/93b21413b4ee99b7bc0dd34e1416fd
> ca96866aaf/powermock-api-support-1.6.2.jar:/home/
> pcoquentin/.gradle/caches/modules-2/files-2.1/org.
> powermock/powermock-core/1.6.2/ea04e79244e19dcf0c3ccf6863c5b0
> 28b4b58c9c/powermock-core-1.6.2.jar:/home/pcoquentin/.
> gradle/caches/modules-2/files-2.1/org.powermock/powermock-
> module-junit4/1.6.2/dff58978da716e000463bc1b08013d
> 6a7cf3d696/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/c7f4ea230aedc757ca1499ebcfb295
> 3c81cf8b67/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/5b9b8b10227ea87eceba16afd22dc4
> 9579fb55b7/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/42825651e29d1b850699233687a076
> 7063bef153/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/7238b064d1aba20da2ac03217d700d
> 91e02460fa/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/8fc09a51ca267726ffd284ab4de7c0
> 2f667da2ad/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/a015c944e8018fb337075ee7c74876
> 133cee555f/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/197d803ab63dd3523d9df186505fc1
> cc93044334/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/caa3ead3ab38ecaa979ec7054fdfc1
> b73d36f916/spring-test-4.0.5.RELEASE.jar:/home/pcoquentin/.
> gradle/caches/modules-2/files-2.1/org.springframework/
> spring-tx/3.2.8.RELEASE/af44bdd6dd44557f6a03021a7d2721
> bbf1708ec1/spring-tx-3.2.8.RELEASE.jar:/home/pcoquentin/.
> gradle/caches/modules-2/files-2.1/org.springframework/
> spring-web/4.0.5.RELEASE/1819f6d4ab65fb33e19c492d5c5aa2
> 1396e42b3f/spring-web-4.0.5.RELEASE.jar:/home/pcoquentin/.
> gradle/caches/modules-2/files-2.1/org.springframework/
> spring-webmvc/4.0.5.RELEASE/2459455b0f2e19e7a51fc7bff4de34
> 1947d9bc57/spring-webmvc-4.0.5.RELEASE.jar:/home/
> pcoquentin/.gradle/caches/modules-2/files-2.1/org.
> fusesource.wikitext/textile-core/1.3/92884d64ac3b825b52bbfee44d661b
> 6cfae36b4c/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/fed19191e861d66315d9ff00484ec9
> 2106c41644/tomcat-servlet-api-8.0.21.jar:/home/pcoquentin/.
> gradle/caches/modules-2/files-2.1/javax.validation/
> validation-api/1.1.0.Final/8613ae82954779d518631e05daa73a
> 6a954817d5/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/3bf3f17fe41fb34c4d98663957ec07
> 95a6b6653e/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/9c64274b7dbb65288237216e3fae78
> 77fd3f2bee/xz-1.5.jar:/home/pcoquentin/.gradle/caches/
> modules-2/files-2.1/com.101tec/zkclient/0.8/c0f700a4a3b386279d7d8dd164edec
> be836cbfdb/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/7539c264413b9b1ff9841cd00058c9
> 74b7cd1ec9/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
>
>
>
