Skip to content

Instantly share code, notes, and snippets.

@ethrbunny
Created August 31, 2016 11:35
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save ethrbunny/387a5a75301694623adea052646281c0 to your computer and use it in GitHub Desktop.
Save ethrbunny/387a5a75301694623adea052646281c0 to your computer and use it in GitHub Desktop.
output from debug session
2016-08-31 04:15:53,668 [main] INFO o.a.k.common.utils.AppInfoParser - Kafka version : 0.10.0.0
2016-08-31 04:15:53,668 [main] INFO o.a.k.common.utils.AppInfoParser - Kafka commitId : b8642491e78c5a13
2016-08-31 04:15:53,670 [main] INFO o.apache.kafka.streams.KafkaStreams - Started Kafka Stream process
2016-08-31 04:15:53,670 [StreamThread-1] INFO o.a.k.s.p.internals.StreamThread - Starting stream thread [StreamThread-1]
2016-08-31 04:15:54,433 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - Discovered coordinator 54.171.235.244:9092 (id: 2147483547 rack: null) for group kafka_test1.
2016-08-31 04:15:54,433 [StreamThread-1] INFO o.a.k.c.c.i.ConsumerCoordinator - Revoking previously assigned partitions [] for group kafka_test1
2016-08-31 04:15:54,433 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - (Re-)joining group kafka_test1
2016-08-31 04:15:54,803 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - Completed validating internal topics in partition assignor.
2016-08-31 04:15:54,804 [StreamThread-1] INFO o.a.k.s.p.i.assignment.TaskAssignor - Assigning tasks to clients: {7f402184-528f-4e0b-a6c5-3cd275e922da=[activeTasks: ([]) assignedTasks: ([]) prevActiveTasks: ([]) prevAssignedTasks: ([]) capacity: 1.0 cost: 0.0]}, prevAssignmentBalanced: false, prevClientsUnchangeed: false, tasks: [0_0, 0_1], replicas: 0
2016-08-31 04:15:54,805 [StreamThread-1] INFO o.a.k.s.p.i.assignment.TaskAssignor - Assigned with: {7f402184-528f-4e0b-a6c5-3cd275e922da=[activeTasks: ([0_0, 0_1]) assignedTasks: ([0_0, 0_1]) prevActiveTasks: ([]) prevAssignedTasks: ([]) capacity: 1.0 cost: 1.0]}
2016-08-31 04:15:54,807 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - Completed validating internal topics in partition assignor.
2016-08-31 04:15:54,808 [StreamThread-1] INFO o.a.k.s.p.i.StreamPartitionAssignor - Completed validating internal topics in partition assignor.
2016-08-31 04:15:54,982 [StreamThread-1] INFO o.a.k.c.c.i.AbstractCoordinator - Successfully joined group kafka_test1 with generation 1
2016-08-31 04:15:54,984 [StreamThread-1] INFO o.a.k.c.c.i.ConsumerCoordinator - Setting newly assigned partitions [video-1, video-0] for group kafka_test1
2016-08-31 04:15:54,997 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - Creating restoration consumer client for stream task #0_0
2016-08-31 04:15:55,171 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - init
2016-08-31 04:15:55,172 [StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - Creating restoration consumer client for stream task #0_1
2016-08-31 04:15:55,172 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - init
2016-08-31 04:16:01,610 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472586621612 count: 1
2016-08-31 04:16:01,790 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472586621773 count: 1
2016-08-31 04:18:19,941 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:19,942 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240516 count: 10238
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,415 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:18:37,416 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587240347 count: 11010
2016-08-31 04:20:17,375 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587251812 count: 18418
2016-08-31 04:20:34,762 [StreamThread-1] INFO c.c.ads.kafkaziplinetest.tmp.BP2 - punctuate ts: 1472587251664 count: 19421
Disconnected from the target VM, address: '127.0.0.1:57233', transport: 'socket'
Process finished with exit code 130
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment