Hi, is that the complete log? It looks like there might be 2 tasks that are still restoring: 2017-09-22 14:08:09 DEBUG AssignedTasks:90 - stream-thread [argyle-streams-fp-StreamThread-6] transitioning stream task 1_18 to restoring 2017-09-22 14:08:09 DEBUG AssignedTasks:90 - stream-thread [argyle-streams-fp-StreamThread-23] transitioning stream task 1_14 to restoring
I don't see them transitioning to running. On Fri, 22 Sep 2017 at 22:21 Ara Ebrahimi <ara.ebrah...@argyledata.com> wrote: > I enabled TRACE level logging for kafka streams package and all I see is > things like this: > > 2017-09-22 14:15:18 INFO StreamThread:686 - stream-thread > [argyle-streams-fp-StreamThread-32] Committed all active tasks [0_30] and > standby tasks [] in 0ms > 2017-09-22 14:15:18 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:18 INFO StreamThread:686 - stream-thread > [argyle-streams-fp-StreamThread-18] Committed all active tasks [0_4] and > standby tasks [] in 0ms > 2017-09-22 14:15:18 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:18 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:18 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:18 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:18 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:18 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:18 DEBUG StreamTask:259 - task [0_29] Committing > 2017-09-22 14:15:18 DEBUG RecordCollectorImpl:142 - task [0_29] Flushing > producer > 2017-09-22 14:15:18 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:18 DEBUG StreamTask:259 - task [0_1] Committing > 2017-09-22 14:15:18 DEBUG RecordCollectorImpl:142 - task [0_1] Flushing > producer > 2017-09-22 14:15:18 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:18 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:18 INFO StreamThread:686 - stream-thread > [argyle-streams-fp-StreamThread-14] Committed all active tasks [0_29] and > standby tasks [] in 0ms > 2017-09-22 14:15:18 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 INFO StreamThread:686 - stream-thread > [argyle-streams-fp-StreamThread-16] Committed all active tasks [0_1] and > standby tasks [] in 0ms > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-6] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-17] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-23] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-6] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-17] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StreamTask:259 - task [0_2] Committing > 2017-09-22 14:15:19 DEBUG RecordCollectorImpl:142 - task [0_2] Flushing > producer > 2017-09-22 14:15:19 DEBUG StreamTask:259 - task [0_26] Committing > 2017-09-22 14:15:19 DEBUG RecordCollectorImpl:142 - task [0_26] Flushing > producer > 2017-09-22 14:15:19 DEBUG StreamTask:259 - task [0_0] Committing > 2017-09-22 14:15:19 DEBUG RecordCollectorImpl:142 - task [0_0] Flushing > producer > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-23] completed partitions [] > 2017-09-22 14:15:19 INFO StreamThread:686 - stream-thread > [argyle-streams-fp-StreamThread-30] Committed all active tasks [0_2] and > standby tasks [] in 0ms > 2017-09-22 14:15:19 DEBUG StreamTask:259 - task [0_16] Committing > 2017-09-22 14:15:19 INFO StreamThread:686 - stream-thread > [argyle-streams-fp-StreamThread-27] Committed all active tasks [0_26] and > standby tasks [] in 0ms > 2017-09-22 14:15:19 DEBUG RecordCollectorImpl:142 - task [0_16] Flushing > producer > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 INFO StreamThread:686 - stream-thread > [argyle-streams-fp-StreamThread-7] Committed all active tasks [0_0, 0_16] > and standby tasks [] in 0ms > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-6] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-17] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-23] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-6] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-17] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-23] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-6] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-17] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-23] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-6] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-17] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-23] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-6] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-17] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-23] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-6] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-17] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-23] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-6] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-17] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-23] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-11] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-24] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-22] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-9] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-26] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-25] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-27] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-3] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-2] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-32] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-20] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-19] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-12] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-33] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-14] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-29] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-31] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-30] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-15] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-4] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-18] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-8] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-5] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-16] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-13] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-10] completed partitions [] > 2017-09-22 14:15:19 DEBUG StoreChangelogReader:194 - stream-thread > [argyle-streams-fp-StreamThread-28] completed partitions [] > > This is what I see upon startup: > > 2017-09-22 14:07:47 INFO StreamsConfig:223 - StreamsConfig values: > application.id = argyle-streams-fp > application.server = > bootstrap.servers = [b3.colo.argyledata.com:9092< > http://b3.colo.argyledata.com:9092>, b2.colo.argyledata.com:9092< > http://b2.colo.argyledata.com:9092>] > buffered.records.per.partition = 1 > cache.max.bytes.buffering = 0 > client.id = argyle-streams-fp > commit.interval.ms = 30000 > connections.max.idle.ms = 540000 > default.key.serde = class > org.apache.kafka.common.serialization.Serdes$StringSerde > default.timestamp.extractor = class > com.argyledata.streams.entity.EntityEventTimeExtractor > default.value.serde = class > org.apache.kafka.common.serialization.Serdes$StringSerde > key.serde = null > metadata.max.age.ms = 300000 > metric.reporters = [] > metrics.num.samples = 2 > metrics.recording.level = INFO > metrics.sample.window.ms = 30000 > num.standby.replicas = 0 > num.stream.threads = 33 > partition.grouper = class > org.apache.kafka.streams.processor.DefaultPartitionGrouper > poll.ms = 100 > processing.guarantee = at_least_once > receive.buffer.bytes = 131072 > reconnect.backoff.max.ms = 1000 > reconnect.backoff.ms = 50 > replication.factor = 1 > request.timeout.ms = 40000 > retry.backoff.ms = 100 > rocksdb.config.setter = class > com.argyledata.streams.featurization.pipeline.common.util.kafka.FeaturizationPipelineRocksDBConfigSetter > security.protocol = PLAINTEXT > send.buffer.bytes = 131072 > state.cleanup.delay.ms = 1800000 > state.dir = /kafka/1/argyle-streams-featurization-pipeline > timestamp.extractor = null > value.serde = null > windowstore.changelog.additional.retention.ms = 31536000000 > zookeeper.connect = > > 2017-09-22 14:07:47 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-1] Creating consumer client > 2017-09-22 14:07:47 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-1] Creating restore consumer client > 2017-09-22 14:07:47 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-2] Creating consumer client > 2017-09-22 14:07:47 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-2] Creating restore consumer client > 2017-09-22 14:07:47 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-3] Creating consumer client > 2017-09-22 14:07:47 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-3] Creating restore consumer client > 2017-09-22 14:07:47 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-4] Creating consumer client > 2017-09-22 14:07:47 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-4] Creating restore consumer client > 2017-09-22 14:07:47 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-5] Creating consumer client > 2017-09-22 14:07:47 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-5] Creating restore consumer client > 2017-09-22 14:07:47 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-6] Creating consumer client > 2017-09-22 14:07:47 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-6] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-7] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-7] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-8] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-8] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-9] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-9] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-10] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-10] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-11] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-11] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-12] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-12] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-13] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-13] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-14] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-14] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-15] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-15] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-16] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-16] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-17] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-17] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-18] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-18] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-19] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-19] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-20] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-20] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-21] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-21] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-22] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-22] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-23] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-23] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-24] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-24] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-25] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-25] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-26] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-26] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-27] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-27] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-28] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-28] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-29] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-29] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-30] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-30] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-31] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-31] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-32] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-32] Creating restore consumer client > 2017-09-22 14:07:48 INFO StreamThread:415 - stream-thread > [argyle-streams-fp-StreamThread-33] Creating consumer client > 2017-09-22 14:07:48 INFO StreamThread:425 - stream-thread > [argyle-streams-fp-StreamThread-33] Creating restore consumer client > 2017-09-22 14:07:48 INFO PipelineDriver:123 - Starting pipeline... > 2017-09-22 14:07:48 DEBUG KafkaStreams:595 - stream-client > [argyle-streams-fp] Starting Kafka Stream process. > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-3] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-23] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-6] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-28] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-21] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-22] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-20] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-19] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-18] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-17] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-16] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-15] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-14] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-13] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-7] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-12] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-11] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-10] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-9] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-8] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-5] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-1] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-2] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-4] Starting > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-2] State transition from CREATED to RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-1] State transition from CREATED to RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-5] State transition from CREATED to RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-8] State transition from CREATED to RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-9] State transition from CREATED to RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-10] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-11] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-12] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-7] State transition from CREATED to RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-13] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO KafkaStreams:618 - stream-client > [argyle-streams-fp] Started Kafka Stream process > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-14] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-15] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-16] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-17] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-18] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-19] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-20] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-22] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-33] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-32] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-31] Starting > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-21] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-30] Starting > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-28] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-29] Starting > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-6] State transition from CREATED to RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-27] Starting > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-26] Starting > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-23] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-25] Starting > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-3] State transition from CREATED to RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:453 - stream-thread > [argyle-streams-fp-StreamThread-24] Starting > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-25] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-26] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-27] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-29] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-30] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-31] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-32] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-33] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO PipelineDriver:136 - Starting monitoring > manager... > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-4] State transition from CREATED to RUNNING. > 2017-09-22 14:07:48 INFO PipelineDriver:140 - Started monitoring manager. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-24] State transition from CREATED to > RUNNING. > 2017-09-22 14:07:48 INFO PipelineDriver:146 - Starting Kafka topic offset > logger... > 2017-09-22 14:07:48 INFO PipelineDriver:150 - Started Kafka topic offset > logger. > 2017-09-22 14:07:48 INFO PipelineDriver:131 - Started pipeline > successfully: KafkaStreams processID: a9a00b31-6678-4fde-b24a-59b41d6caaee > > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-33] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-3] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-1] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-3] State transition from RUNNING to > PARTITIONS_REVOKED. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-33] State transition from RUNNING to > PARTITIONS_REVOKED. > 2017-09-22 14:07:48 INFO KafkaStreams:268 - stream-client > [argyle-streams-fp] State transition from RUNNING to REBALANCING. > 2017-09-22 14:07:48 DEBUG StreamThread:1004 - stream-thread > [argyle-streams-fp-StreamThread-3] Suspending all active tasks [] and > standby tasks [] > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-1] State transition from RUNNING to > PARTITIONS_REVOKED. > 2017-09-22 14:07:48 INFO KafkaStreams:268 - stream-client > [argyle-streams-fp] State transition from REBALANCING to REBALANCING. > 2017-09-22 14:07:48 INFO KafkaStreams:268 - stream-client > [argyle-streams-fp] State transition from REBALANCING to REBALANCING. > 2017-09-22 14:07:48 DEBUG StreamThread:1004 - stream-thread > [argyle-streams-fp-StreamThread-33] Suspending all active tasks [] and > standby tasks [] > 2017-09-22 14:07:48 DEBUG StreamThread:1004 - stream-thread > [argyle-streams-fp-StreamThread-1] Suspending all active tasks [] and > standby tasks [] > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-18] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-18] State transition from RUNNING to > PARTITIONS_REVOKED. > 2017-09-22 14:07:48 INFO KafkaStreams:268 - stream-client > [argyle-streams-fp] State transition from REBALANCING to REBALANCING. > 2017-09-22 14:07:48 DEBUG StreamThread:1004 - stream-thread > [argyle-streams-fp-StreamThread-18] Suspending all active tasks [] and > standby tasks [] > 2017-09-22 14:07:48 INFO StreamThread:229 - stream-thread > [argyle-streams-fp-StreamThread-3] partition revocation took 10 ms. > suspended active tasks: [] > suspended standby tasks: [] > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-23] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-26] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 INFO StreamThread:229 - stream-thread > [argyle-streams-fp-StreamThread-33] partition revocation took 12 ms. > suspended active tasks: [] > suspended standby tasks: [] > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-7] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 INFO StreamThread:229 - stream-thread > [argyle-streams-fp-StreamThread-18] partition revocation took 2 ms. > suspended active tasks: [] > suspended standby tasks: [] > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-7] State transition from RUNNING to > PARTITIONS_REVOKED. > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-8] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-8] State transition from RUNNING to > PARTITIONS_REVOKED. > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-19] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-19] State transition from RUNNING to > PARTITIONS_REVOKED. > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-4] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-4] State transition from RUNNING to > PARTITIONS_REVOKED. > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-16] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-29] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 INFO KafkaStreams:268 - stream-client > [argyle-streams-fp] State transition from REBALANCING to REBALANCING. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-29] State transition from RUNNING to > PARTITIONS_REVOKED. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-23] State transition from RUNNING to > PARTITIONS_REVOKED. > 2017-09-22 14:07:48 INFO StreamThread:888 - stream-thread > [argyle-streams-fp-StreamThread-16] State transition from RUNNING to > PARTITIONS_REVOKED. > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-10] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 INFO StreamThread:229 - stream-thread > [argyle-streams-fp-StreamThread-1] partition revocation took 18 ms. > suspended active tasks: [] > suspended standby tasks: [] > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-30] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 INFO KafkaStreams:268 - stream-client > [argyle-streams-fp] State transition from REBALANCING to REBALANCING. > 2017-09-22 14:07:48 DEBUG StreamThread:1004 - stream-thread > [argyle-streams-fp-StreamThread-7] Suspending all active tasks [] and > standby tasks [] > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-21] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-9] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-25] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-31] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 DEBUG StreamThread:209 - stream-thread > [argyle-streams-fp-StreamThread-28] at state RUNNING: partitions [] revoked > at the beginning of consumer rebalance. > current assigned active tasks: [] > current assigned standby tasks: [] > > 2017-09-22 14:07:48 INFO KafkaStreams:268 - stream-client > [argyle-streams-fp] State transition from REBALANCING to REBALANCING.<
