I hereby claim:
- I am mfenniak on github.
- I am mfenniak (https://keybase.io/mfenniak) on keybase.
- I have a public key ASBszYEV6fmIrudDoq2iEuw_FwT_X1WqTd3ECfOA-wfF9Ao
To claim this, I am signing this object:
Mathieu Fenniak mfenniak
mfenniak
/ osx-pg-walsender-samples.txt
Created
May 5, 2017 20:19
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Analysis of sampling postgres (pid 32304) every 1 millisecond | |
| Process: postgres [32304] | |
| Path: /usr/local/Cellar/postgresql/9.6.2/bin/postgres | |
| Load Address: 0x10d9c1000 | |
| Identifier: postgres | |
| Version: 0 | |
| Code Type: X86-64 | |
| Parent Process: postgres [1006] | |
| Date/Time: 2017-05-05 14:07:12.371 -0600 |
mfenniak
/ gist:c56beb6d5058e2b21df0309aea224f12
Created
March 17, 2017 17:25
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 22:24:58.587 [StreamThread-1] ERROR o.a.k.c.c.i.ConsumerCoordinator - User provided listener org.apache.kafka.streams.processor.internals.StreamThread$1 for group timesheet-list failed on partition assignmen | |
| t | |
| org.apache.kafka.streams.errors.ProcessorStateException: Error opening store ServiceCenterParentFlatMap-topic at location /tmp/kafka-streams/timesheet-list/33_5/rocksdb/ServiceCenterParentFlatMap-topic | |
| at org.apache.kafka.streams.state.internals.RocksDBStore.openDB(RocksDBStore.java:173) | |
| at org.apache.kafka.streams.state.internals.RocksDBStore.openDB(RocksDBStore.java:143) | |
| at org.apache.kafka.streams.state.internals.RocksDBStore.init(RocksDBStore.java:148) | |
| at org.apache.kafka.streams.state.internals.MeteredKeyValueStore$7.run(MeteredKeyValueStore.java:100) | |
| at org.apache.kafka.streams.processor.internals.StreamsMetricsImpl.measureLatencyNs(StreamsMetricsImpl.java:188) | |
| at org.apache.kafka.streams.state.internals.MeteredKeyValueStore.init(MeteredKeyValueStore |
mfenniak
/ log-sequence-CommitFailedException.log
Created
March 10, 2017 18:03
Log output & sequence from Kafka Streams CommitFailedException
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| App starts up. Consumer config is logged showing max.poll.interval.ms = 1800000 (30 minutes) | |
| { | |
| "timestamp":"2017-03-08T22:13:51.139+00:00", | |
| "message":"ConsumerConfig values: | |
| auto.commit.interval.ms = 5000 | |
| auto.offset.reset = earliest | |
| bootstrap.servers = [10.20.4.219:9092, 10.20.6.54:9092] | |
| check.crcs = true | |
| client.id = timesheet-list-3d89bd2e-941f-4272-9916-aad4e6f82e36-StreamThread-1-consumer | |
| connections.max.idle.ms = 540000 |
mfenniak
/ Kafka Streams topology to Graphviz.kt
Created
February 7, 2017 14:24
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| fun printGraphviz(builder: TopologyBuilder) { | |
| println("digraph {") | |
| val nodeGroups = builder.nodeGroups() | |
| val processorTopologys = nodeGroups.map { kv -> builder.build(kv.key) } | |
| val sourceTopics = processorTopologys.flatMap { it.sourceTopics() } | |
| val sinkTopics = processorTopologys.flatMap { it.sinkTopics() } | |
| val allTopics = sourceTopics.plus(sinkTopics).distinct().sorted() | |
| println(" node [shape=\"rect\"]") |
mfenniak
/ InvalidStateStoreException log
Created
February 2, 2017 16:02
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ... more running log data ... | |
| 15:51:30.488 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Flushing state stores of task 19_2 | |
| 15:51:30.488 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Flushing state stores of task 20_1 | |
| 15:51:30.488 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Flushing state stores of task 21_1 | |
| 15:51:30.488 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Flushing state stores of task 21_3 | |
| 15:51:30.489 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 2_0 | |
| 15:51:30.501 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 3_0 | |
| 15:51:30.501 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] Closing the state manager of task 1_2 | |
| 15:51:30.518 [StreamThread |
mfenniak
/ gist:509fb82dfcfda79a21cfc1b07dafa89c
Created
December 4, 2016 03:43
kafka-streams error w/ trunk @ e43bbce
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| java.lang.IllegalStateException: Attempting to put a clean entry for key [urn:replicon-tenant:strprc971e3ca9:timesheet:97c0ce25-e039-4e8b-9f2c-d43f0668b755] into NamedCache [0_0-TimesheetNonBillableHours] when it already contains a dirty entry for the same key | |
| at org.apache.kafka.streams.state.internals.NamedCache.put(NamedCache.java:124) | |
| at org.apache.kafka.streams.state.internals.ThreadCache.put(ThreadCache.java:120) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.get(CachingKeyValueStore.java:146) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.get(CachingKeyValueStore.java:133) | |
| at org.apache.kafka.streams.kstream.internals.KTableAggregate$KTableAggregateValueGetter.get(KTableAggregate.java:128) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinProcessor.process(KTableKTableLeftJoin.java:81) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinProcessor.process(KTableKTableLeftJoin.java:54) | |
| at o |
mfenniak
/ keybase.md
Created
August 18, 2016 03:28
mfenniak
/ gist:11ca081191932fbb33a0c3cc32ad1686
Last active
August 10, 2016 14:22
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| org.apache.kafka.streams.errors.TopologyBuilderException: Invalid topology building: External source topic not found: TableNumber2Aggregated-repartition | |
| at org.apache.kafka.streams.processor.internals.StreamPartitionAssignor.ensureCopartitioning(StreamPartitionAssignor.java:452) | |
| at org.apache.kafka.streams.processor.internals.StreamPartitionAssignor.ensureCopartitioning(StreamPartitionAssignor.java:440) | |
| at org.apache.kafka.streams.processor.internals.StreamPartitionAssignor.assign(StreamPartitionAssignor.java:267) | |
| at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.performAssignment(ConsumerCoordinator.java:260) | |
| at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.onJoinLeader(AbstractCoordinator.java:404) | |
| at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.access$900(AbstractCoordinator.java:81) | |
| at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:358) | |
| at org.apache.kafka.clients.consume |
mfenniak
/ vagrant.log
Last active
August 4, 2016 13:57
vagrant debug log for hashicorp/vagrant#7682
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| INFO global: Vagrant version: 1.8.5 | |
| INFO global: Ruby version: 2.2.3 | |
| INFO global: RubyGems version: 2.4.5.1 | |
| INFO global: VAGRANT_EXECUTABLE="C:\\HashiCorp\\Vagrant\\embedded\\gems\\gems\\vagrant-1.8.5\\bin\\vagrant" | |
| INFO global: VAGRANT_INSTALLER_EMBEDDED_DIR="C:\\HashiCorp\\Vagrant\\embedded" | |
| INFO global: VAGRANT_INSTALLER_ENV="1" | |
| INFO global: VAGRANT_INSTALLER_VERSION="2" | |
| INFO global: VAGRANT_INTERNAL_BUNDLERIZED="1" | |
| INFO global: VAGRANT_LOG="debug" | |
| INFO global: VAGRANT_OLD_ENV_="ExitCode=00000001" |
mfenniak
/ index.js
Created
June 7, 2016 13:58
Example implementation of disabling loading of a specific fortunejs relationship (fortunejs/fortune#219)
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 'use strict'; | |
| const fortune = require('fortune'); | |
| const http = require('http'); | |
| const JsonApiSerializer = require('fortune-json-api'); | |
| const MemoryAdapter = require('fortune/lib/adapter/adapters/memory'); | |
| const HttpSerializer = fortune.net.http.Serializer; | |
| const store = fortune( | |
| { |