I hereby claim:
- I am lbradstreet on github.
- I am lbradstreet (https://keybase.io/lbradstreet) on keybase.
- I have a public key ASBUKrBU43JiTDLj-Hg6HyfPMXk3EI4wTgcFQ3cHEMofuAo
To claim this, I am signing this object:
lein test onyx.peer.dashboard-colors-flow-test | |
STARTED | |
================================= | |
Starting Dashboard components ... | |
Starting Sente | |
18-12-10 04:36:37 vath.local INFO [onyx.messaging.aeron.status-publisher:51] - Closing status pub {:completed? true, :src-peer-id #uuid "94d8d5d7-5856-5025-5786-158432325fda", :site {:address "localhost", :port 40200}, :blocked? false, :pos 6976, :type :status-publisher, :stream-id 0, :checkpoint? true, :dst-channel "aeron:udp?endpoint=localhost:40200|term-length=4194304", :dst-peer-id [:coordinator #uuid "94d8d5d7-5856-5025-5786-158432325fda"], :dst-session-id 674235127, :short-id 1, :status-session-id 674235134} | |
Starting Channels | |
Starting ZKClient | |
18-12-10 04:36:37 vath.local INFO [onyx.peer.coordinator:350] - Stopping coordinator on: 94d8d5d7-5856-5025-5786-158432325fda |
version: '2' | |
services: | |
zoo1: | |
image: zookeeper:3.4.9 | |
restart: unless-stopped | |
hostname: zoo1 | |
ports: | |
- "2181:2181" | |
environment: |
I hereby claim:
To claim this, I am signing this object:
--- service: name: sensor-counts | |
doc: "A streaming microservice." | |
operations: | |
- operation: readFromTopic | |
params: | |
topicId: << Fill me in >> |
[779236.115026] CMD_IN_ADD_SUBSCRIPTION [66/66]: aeron:udp?endpoint=localhost:40199 -361206136 [-1][1:4] | |
[779236.135770] RECEIVE_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0 | |
[779236.138427] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:4] | |
[779236.138563] CMD_IN_ADD_SUBSCRIPTION [66/66]: aeron:udp?endpoint=localhost:40199 -1576507014 [-1][0:5] | |
[779236.138717] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:5] | |
[779236.138729] CMD_IN_ADD_SUBSCRIPTION [66/66]: aeron:udp?endpoint=localhost:40199 814924295 [-1][2:3] | |
[779236.138784] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:3] | |
[779236.162943] CMD_IN_ADD_PUBLICATION [58/58]: aeron:udp?endpoint=localhost:40199 0 [8:10] | |
[779236.165131] SEND_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0 | |
[779236.294991] CMD_OUT_PUBLICATION_READY [150/150]: 421743339:0 28 [10] |
[779236.115026] CMD_IN_ADD_SUBSCRIPTION [66/66]: aeron:udp?endpoint=localhost:40199 -361206136 [-1][1:4] | |
[779236.135770] RECEIVE_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0 | |
[779236.138427] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:4] | |
[779236.138563] CMD_IN_ADD_SUBSCRIPTION [66/66]: aeron:udp?endpoint=localhost:40199 -1576507014 [-1][0:5] | |
[779236.138717] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:5] | |
[779236.138729] CMD_IN_ADD_SUBSCRIPTION [66/66]: aeron:udp?endpoint=localhost:40199 814924295 [-1][2:3] | |
[779236.138784] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:3] | |
[779236.162943] CMD_IN_ADD_PUBLICATION [58/58]: aeron:udp?endpoint=localhost:40199 0 [8:10] | |
[779236.165131] SEND_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0 | |
[779236.294991] CMD_OUT_PUBLICATION_READY [150/150]: 421743339:0 28 [10] |
Command `n Control file /var/folders/d8/6x6y27ln2f702g56jzzh9h780000gn/T/aeron-lucas/cnc.dat | |
[H[2J22:50:39 - Aeron Stat | |
========================= | |
0: 0 - Bytes sent | |
1: 0 - Bytes received | |
2: 0 - Failed offers to ReceiverProxy | |
3: 0 - Failed offers to SenderProxy | |
4: 0 - Failed offers to DriverConductorProxy | |
5: 0 - NAKs sent | |
6: 0 - NAKs received |
[735197.279306] RECEIVE_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0 | |
[735197.283190] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:3] | |
[735197.283439] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:2] | |
[735197.283504] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:5] | |
[735197.301572] SEND_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0 | |
[735197.388816] CMD_OUT_PUBLICATION_READY [150/150]: -264882356:0 28 [10] | |
[735197.388960] CMD_OUT_PUBLICATION_READY [150/150]: -264882356:0 28 [9] | |
[735197.389026] CMD_OUT_PUBLICATION_READY [150/150]: -264882356:0 28 [11] | |
[735197.495163] CMD_OUT_PUBLICATION_READY [157/157]: -264882355:-41950782 31 [13] | |
[735197.580585] CMD_OUT_PUBLICATION_READY [157/157]: -264882354:-213634344 34 [15] |
[726462.051452] RECEIVE_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0 | |
[726462.054697] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:3] | |
[726462.054944] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:2] | |
[726462.055003] CMD_OUT_ON_OPERATION_SUCCESS [16/16]: [0:5] | |
[726462.071602] SEND_CHANNEL_CREATION [108/108]: UdpChannel - localData: 0.0.0.0/0.0.0.0:0, remoteData: localhost/127.0.0.1:40199, ttl: 0 | |
[726462.250009] CMD_OUT_PUBLICATION_READY [150/150]: -120940798:0 28 [8] | |
[726462.250278] CMD_OUT_PUBLICATION_READY [150/150]: -120940798:0 28 [10] | |
[726462.250377] CMD_OUT_PUBLICATION_READY [150/150]: -120940798:0 28 [11] | |
[726462.400089] CMD_OUT_PUBLICATION_READY [156/156]: -120940797:101989262 31 [13] | |
[726462.492061] CMD_OUT_PUBLICATION_READY [156/156]: -120940796:164441944 34 [15] |
kafka client metrics | |
; (.value | |
; (get (keys (into {} (map (juxt #(.name (key %)) val) (.metrics (:producer (:topic-producer (deref system))))))) | |
; "connection-count")) |