Skip to content

Instantly share code, notes, and snippets.

@jyates

jyates/.log

Last active July 15, 2020 18:31
Show Gist options
  • Save jyates/e9b761f14c05a1fff78e08e9262203fa to your computer and use it in GitHub Desktop.
Save jyates/e9b761f14c05a1fff78e08e9262203fa to your computer and use it in GitHub Desktop.
Download ZIP
alpakka #1159 logs
Raw
.log
2020-07-15 17:53:23 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.e.s.Slf4jLogger:101 - Slf4jLogger started
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:92 - ---- Initializing KafkaRawToCanonical channel ---
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:19 - Current configuration:
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - LOG_OUTPUT_LEVEL: "INFO"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - LOG_OUTPUT_TYPE: "stdout"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.allow-java-serialization: "on"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.creation-timeout: "20s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.debug.autoreceive: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.debug.event-stream: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.debug.fsm: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.debug.lifecycle: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.debug.receive: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.debug.router-misconfiguration: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.debug.unhandled: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-blocking-io-dispatcher.executor: "thread-pool-executor"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-blocking-io-dispatcher.thread-pool-executor.fixed-pool-size: 16
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-blocking-io-dispatcher.throughput: 1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-blocking-io-dispatcher.type: "Dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.affinity-pool-executor.fair-work-distribution.threshold: 128
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.affinity-pool-executor.idle-cpu-level: 5
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.affinity-pool-executor.parallelism-factor: 0.8
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.affinity-pool-executor.parallelism-max: 64
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.affinity-pool-executor.parallelism-min: 4
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.affinity-pool-executor.queue-selector: "akka.dispatch.affinity.FairDistributionHashCache"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.affinity-pool-executor.rejection-handler: "akka.dispatch.affinity.ThrowOnOverflowRejectionHandler"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.affinity-pool-executor.task-queue-size: 512
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.attempt-teamwork: "on"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.default-executor.fallback: "fork-join-executor"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.executor: "default-executor"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.fork-join-executor.parallelism-factor: 3
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.fork-join-executor.parallelism-max: 4
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.fork-join-executor.parallelism-min: 8
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.fork-join-executor.task-peeking-mode: "FIFO"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.mailbox-requirement: ""
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.shutdown-timeout: "1s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.thread-pool-executor.allow-core-timeout: "on"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.thread-pool-executor.core-pool-size-factor: 3
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.thread-pool-executor.core-pool-size-max: 64
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.thread-pool-executor.core-pool-size-min: 8
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.thread-pool-executor.fixed-pool-size: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.thread-pool-executor.keep-alive-time: "60s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.thread-pool-executor.max-pool-size-factor: 3
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.thread-pool-executor.max-pool-size-max: 64
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.thread-pool-executor.max-pool-size-min: 8
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.thread-pool-executor.task-queue-size: -1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.thread-pool-executor.task-queue-type: "linked"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.throughput: 5
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.throughput-deadline-time: "0ms"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-dispatcher.type: "Dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-mailbox.mailbox-capacity: 1000
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-mailbox.mailbox-push-timeout-time: "10s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-mailbox.mailbox-type: "akka.dispatch.UnboundedMailbox"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.default-mailbox.stash-capacity: -1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment."/IO-DNS/async-dns".mailbox: "unbounded"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment."/IO-DNS/async-dns".nr-of-instances: 1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment."/IO-DNS/async-dns".router: "round-robin-pool"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment."/IO-DNS/inet-address".mailbox: "unbounded"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment."/IO-DNS/inet-address".nr-of-instances: 4
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment."/IO-DNS/inet-address".router: "consistent-hashing-pool"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment."/IO-DNS/inet-address/*".dispatcher: "akka.actor.default-blocking-io-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.dispatcher: ""
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.mailbox: ""
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.nr-of-instances: 1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.optimal-size-exploring-resizer.action-interval: "5s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.optimal-size-exploring-resizer.chance-of-exploration: 0.4
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.optimal-size-exploring-resizer.chance-of-ramping-down-when-full: 0.2
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.optimal-size-exploring-resizer.downsize-after-underutilized-for: "72h"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.optimal-size-exploring-resizer.downsize-ratio: 0.8
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.optimal-size-exploring-resizer.enabled: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.optimal-size-exploring-resizer.explore-step-size: 0.1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.optimal-size-exploring-resizer.lower-bound: 1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.optimal-size-exploring-resizer.optimization-range: 16
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.optimal-size-exploring-resizer.upper-bound: 10
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.optimal-size-exploring-resizer.weight-of-latest-metric: 0.5
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.resizer.backoff-rate: 0.1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.resizer.backoff-threshold: 0.3
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.resizer.enabled: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.resizer.lower-bound: 1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.resizer.messages-per-resize: 10
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.resizer.pressure-threshold: 1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.resizer.rampup-rate: 0.2
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.resizer.upper-bound: 10
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.routees.paths: []
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.router: "from-code"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.tail-chopping-router.interval: "10 milliseconds"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.virtual-nodes-factor: 10
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.deployment.default.within: "5 seconds"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.dsl.default-timeout: "5s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.dsl.inbox-size: 1000
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.enable-additional-serialization-bindings: "on"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.guardian-supervisor-strategy: "akka.actor.DefaultSupervisorStrategy"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.bounded-control-aware-queue-based.mailbox-type: "akka.dispatch.BoundedControlAwareMailbox"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.bounded-deque-based.mailbox-type: "akka.dispatch.BoundedDequeBasedMailbox"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.bounded-queue-based.mailbox-type: "akka.dispatch.BoundedMailbox"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.logger-queue.mailbox-type: "akka.event.LoggerMailboxType"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.requirements."akka.dispatch.BoundedControlAwareMessageQueueSemantics": "akka.actor.mailbox.bounded-control-aware-queue-based"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.requirements."akka.dispatch.BoundedDequeBasedMessageQueueSemantics": "akka.actor.mailbox.bounded-deque-based"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.requirements."akka.dispatch.BoundedMessageQueueSemantics": "akka.actor.mailbox.bounded-queue-based"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.requirements."akka.dispatch.ControlAwareMessageQueueSemantics": "akka.actor.mailbox.unbounded-control-aware-queue-based"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.requirements."akka.dispatch.DequeBasedMessageQueueSemantics": "akka.actor.mailbox.unbounded-deque-based"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.requirements."akka.dispatch.MultipleConsumerSemantics": "akka.actor.mailbox.unbounded-queue-based"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.requirements."akka.dispatch.UnboundedControlAwareMessageQueueSemantics": "akka.actor.mailbox.unbounded-control-aware-queue-based"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.requirements."akka.dispatch.UnboundedDequeBasedMessageQueueSemantics": "akka.actor.mailbox.unbounded-deque-based"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.requirements."akka.dispatch.UnboundedMessageQueueSemantics": "akka.actor.mailbox.unbounded-queue-based"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.requirements."akka.event.LoggerMessageQueueSemantics": "akka.actor.mailbox.logger-queue"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.unbounded-control-aware-queue-based.mailbox-type: "akka.dispatch.UnboundedControlAwareMailbox"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.unbounded-deque-based.mailbox-type: "akka.dispatch.UnboundedDequeBasedMailbox"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.mailbox.unbounded-queue-based.mailbox-type: "akka.dispatch.UnboundedMailbox"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.provider: "local"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.balancing-pool: "akka.routing.BalancingPool"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.broadcast-group: "akka.routing.BroadcastGroup"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.broadcast-pool: "akka.routing.BroadcastPool"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.consistent-hashing-group: "akka.routing.ConsistentHashingGroup"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.consistent-hashing-pool: "akka.routing.ConsistentHashingPool"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.from-code: "akka.routing.NoRouter"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.random-group: "akka.routing.RandomGroup"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.random-pool: "akka.routing.RandomPool"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.round-robin-group: "akka.routing.RoundRobinGroup"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.round-robin-pool: "akka.routing.RoundRobinPool"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.scatter-gather-group: "akka.routing.ScatterGatherFirstCompletedGroup"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.scatter-gather-pool: "akka.routing.ScatterGatherFirstCompletedPool"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.smallest-mailbox-pool: "akka.routing.SmallestMailboxPool"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.tail-chopping-group: "akka.routing.TailChoppingGroup"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.router.type-mapping.tail-chopping-pool: "akka.routing.TailChoppingPool"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serialization-bindings."[B": "bytes"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serialization-bindings."akka.stream.SinkRef": "akka-stream-ref"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serialization-bindings."akka.stream.SourceRef": "akka-stream-ref"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serialization-bindings."akka.stream.impl.streamref.StreamRefsProtocol": "akka-stream-ref"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serialization-bindings."java.io.Serializable": "java"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serialization-identifiers."akka.serialization.BooleanSerializer": 35
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serialization-identifiers."akka.serialization.ByteArraySerializer": 4
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serialization-identifiers."akka.serialization.JavaSerializer": 1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serialization-identifiers."akka.stream.serialization.StreamRefSerializer": 30
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serialize-creators: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serialize-messages: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serializers.akka-stream-ref: "akka.stream.serialization.StreamRefSerializer"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serializers.bytes: "akka.serialization.ByteArraySerializer"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serializers.java: "akka.serialization.JavaSerializer"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.serializers.primitive-boolean: "akka.serialization.BooleanSerializer"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.typed.timeout: "5s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.unstarted-push-timeout: "10s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.warn-about-java-serializer-usage: "on"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.actor.warn-on-no-serialization-verification: "on"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.default-phase-timeout: "5 s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.exit-code: 0
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.exit-jvm: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.actor-system-terminate.depends-on: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1457
"before-actor-system-terminate"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.actor-system-terminate.timeout: "10 s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.before-actor-system-terminate.depends-on: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1448
"cluster-shutdown"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.before-cluster-shutdown.depends-on: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1408
"service-stop"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.cluster-exiting-done.depends-on: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1436
"cluster-exiting"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.cluster-exiting.depends-on: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1430
"cluster-leave"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.cluster-exiting.timeout: "10 s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.cluster-leave.depends-on: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1421
"cluster-sharding-shutdown-region"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.cluster-sharding-shutdown-region.depends-on: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1415
"before-cluster-shutdown"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.cluster-sharding-shutdown-region.timeout: "10 s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.cluster-shutdown.depends-on: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1442
"cluster-exiting-done"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.service-requests-done.depends-on: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1396
"service-unbind"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.service-stop.depends-on: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1402
"service-requests-done"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.phases.service-unbind.depends-on: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1389
"before-service-unbind"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.reason-overrides."akka.actor.CoordinatedShutdown$ClusterDowningReason$".exit-code: -1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.reason-overrides."akka.actor.CoordinatedShutdown$ClusterJoinUnsuccessfulReason$".exit-code: -1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.run-by-jvm-shutdown-hook: "on"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.coordinated-shutdown.terminate-actor-system: "on"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.daemonic: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.extensions: []
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.home: ""
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.async-dns.cache-cleanup-interval: "120s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.async-dns.nameservers: "default"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.async-dns.ndots: "default"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.async-dns.negative-ttl: "never"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.async-dns.positive-ttl: "forever"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.async-dns.provider-object: "akka.io.dns.internal.AsyncDnsProvider"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.async-dns.resolve-timeout: "5s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.async-dns.search-domains: "default"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.dispatcher: "akka.actor.default-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.inet-address.cache-cleanup-interval: "120s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.inet-address.negative-ttl: "default"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.inet-address.positive-ttl: "default"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.inet-address.provider-object: "akka.io.InetAddressDnsProvider"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.dns.resolver: "inet-address"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.pinned-dispatcher.executor: "thread-pool-executor"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.pinned-dispatcher.thread-pool-executor.allow-core-timeout: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.pinned-dispatcher.type: "PinnedDispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.batch-accept-limit: 10
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.direct-buffer-pool-limit: 1000
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.direct-buffer-size: "128 KiB"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.file-io-dispatcher: "akka.actor.default-blocking-io-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.file-io-transferTo-limit: "512 KiB"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.finish-connect-retries: 5
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.management-dispatcher: "akka.actor.default-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.max-channels: 256000
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.max-received-message-size: "unlimited"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.nr-of-selectors: 1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.register-timeout: "5s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.selector-association-retries: 10
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.selector-dispatcher: "akka.io.pinned-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.trace-logging: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.windows-connection-abort-workaround-enabled: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.tcp.worker-dispatcher: "akka.actor.default-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp-connected.direct-buffer-pool-limit: 1000
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp-connected.direct-buffer-size: "128 KiB"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp-connected.management-dispatcher: "akka.actor.default-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp-connected.max-channels: 4096
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp-connected.nr-of-selectors: 1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp-connected.receive-throughput: 3
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp-connected.select-timeout: "infinite"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp-connected.selector-association-retries: 10
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp-connected.selector-dispatcher: "akka.io.pinned-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp-connected.trace-logging: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp-connected.worker-dispatcher: "akka.actor.default-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp.direct-buffer-pool-limit: 1000
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp.direct-buffer-size: "128 KiB"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp.management-dispatcher: "akka.actor.default-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp.max-channels: 4096
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp.nr-of-selectors: 1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp.receive-throughput: 3
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp.select-timeout: "infinite"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp.selector-association-retries: 10
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp.selector-dispatcher: "akka.io.pinned-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp.trace-logging: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.io.udp.worker-dispatcher: "akka.actor.default-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.jvm-exit-on-fatal-error: "on"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.jvm-shutdown-hooks: "on"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.committer.delivery: "WaitForAck"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.committer.max-batch: 1000
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.committer.max-interval: "10s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.committer.parallelism: 100
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.close-timeout: "20s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.commit-refresh-interval: "infinite"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.commit-time-warning: "1s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.commit-timeout: "15s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.connection-checker.backoff-factor: 2
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.connection-checker.check-interval: "15s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.connection-checker.enable: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.connection-checker.max-retries: 3
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.discovery-method: "akka.discovery"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.eos-draining-check-interval: "30ms"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.kafka-clients.auto.offset.reset: "latest"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.kafka-clients.auto.register.schemas: true
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.kafka-clients.bootstrap.servers: "kafka-brokers:9092"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.kafka-clients.enable.auto.commit: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.kafka-clients.key.deserializer: "org.apache.kafka.common.serialization.ByteArrayDeserializer"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.kafka-clients.max.poll.records: 100
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.kafka-clients.schema.registry.url: "http://schema-registry.com"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.kafka-clients.value.deserializer: "org.apache.kafka.common.serialization.ByteArrayDeserializer"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.metadata-request-timeout: "5s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.offset-for-times-timeout: "5s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.partition-handler-warning: "5s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.poll-interval: "50ms"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.poll-timeout: "50ms"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.position-timeout: "5s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.resolve-timeout: "3 seconds"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.service-name: ""
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.stop-timeout: "30s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.use-dispatcher: "akka.kafka.default-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.consumer.wait-close-partition: "500ms"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.default-dispatcher.executor: "thread-pool-executor"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.default-dispatcher.thread-pool-executor.fixed-pool-size: 16
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.default-dispatcher.type: "Dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.close-on-producer-stop: true
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.close-timeout: "60s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.discovery-method: "akka.discovery"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.eos-commit-interval: "100ms"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.kafka-clients.bootstrap.servers: "kafka-brokers:9092"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.kafka-clients.compression.type: "lz4"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.kafka-clients.key.serializer: "io.confluent.kafka.serializers.KafkaAvroSerializer"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.kafka-clients.linger.ms: 50
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.kafka-clients.schema.registry.url: "http://schema-registry.com"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.kafka-clients.value.serializer: "io.confluent.kafka.serializers.KafkaAvroSerializer"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.parallelism: 5000
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.resolve-timeout: "3 seconds"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.service-name: ""
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.kafka.producer.use-dispatcher: "akka.kafka.default-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.library-extensions: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/pipeline-car-can/src/main/java/com/tesla/data/pipeline/car/can/all_in_one_deploy.jar!/reference.conf: 70
"akka.serialization.SerializationExtension",
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 255
"akka.serialization.SerializationExtension"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.log-config-on-start: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.log-dead-letters: 10
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.log-dead-letters-during-shutdown: "on"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.logger-startup-timeout: "5s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.loggers: [
# akka-overrides.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/akka-overrides.conf: 10
"akka.event.slf4j.Slf4jLogger"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.loggers-dispatcher: "akka.actor.default-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.logging-filter: "akka.event.slf4j.Slf4jLoggingFilter"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.loglevel: "DEBUG"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.scheduler.implementation: "akka.actor.LightArrayRevolverScheduler"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.scheduler.shutdown-timeout: "5s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.scheduler.tick-duration: "10ms"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.scheduler.ticks-per-wheel: 512
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.serialization.protobuf.whitelist-class: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 964
"com.google.protobuf.GeneratedMessage",
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 965
"com.google.protobuf.GeneratedMessageV3",
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 966
"scalapb.GeneratedMessageCompanion",
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 967
"akka.protobuf.GeneratedMessage"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.ssl-config.protocol: "TLSv1.2"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stdout-loglevel: "WARNING"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.blocking-io-dispatcher: "akka.stream.default-blocking-io-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.default-blocking-io-dispatcher.executor: "thread-pool-executor"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.default-blocking-io-dispatcher.thread-pool-executor.fixed-pool-size: 16
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.default-blocking-io-dispatcher.throughput: 1
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.default-blocking-io-dispatcher.type: "Dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.auto-fusing: "on"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.blocking-io-dispatcher: "akka.stream.default-blocking-io-dispatcher"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.debug-logging: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.debug.fuzzing-mode: "off"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.dispatcher: ""
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.initial-input-buffer-size: 4
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.io.tcp.write-buffer-size: "16 KiB"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.max-fixed-buffer-size: 1000000000
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.max-input-buffer-size: 16
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.output-burst-limit: 1000
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.stream-ref.buffer-capacity: 32
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.stream-ref.demand-redelivery-interval: "1 second"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.stream-ref.final-termination-signal-deadline: "2 seconds"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.stream-ref.subscription-timeout: "30 seconds"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.subscription-timeout.mode: "cancel"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.subscription-timeout.timeout: "5s"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.stream.materializer.sync-processing-limit: 1000
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - akka.version: "2.5.29"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - awt.toolkit: "sun.awt.X11.XToolkit"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - config.file: "/opt/tesla/dataworks/service.conf"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - file.encoding.pkg: "sun.io"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - file.separator: "/"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.awt.graphicsenv: "sun.awt.X11GraphicsEnvironment"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.awt.printerjob: "sun.print.PSPrinterJob"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.class.path: "HIDDEN"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.class.version: "52.0"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.endorsed.dirs: "/usr/lib/jvm/java-8-openjdk-amd64/jre/lib/endorsed"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.ext.dirs: "/usr/lib/jvm/java-8-openjdk-amd64/jre/lib/ext:/usr/java/packages/lib/ext"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.home: "/usr/lib/jvm/java-8-openjdk-amd64/jre"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.io.tmpdir: "/tmp"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.library.path: "/usr/java/packages/lib/amd64:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.runtime.name: "OpenJDK Runtime Environment"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.runtime.version: "1.8.0_181-8u181-b13-2~deb9u1-b13"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.specification.name: "Java Platform API Specification"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.specification.vendor: "Oracle Corporation"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.specification.version: "1.8"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.vendor.url.bug: "http://bugreport.sun.com/bugreport/"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.version: "1.8.0_181"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.vm.info: "mixed mode"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.vm.name: "OpenJDK 64-Bit Server VM"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.vm.specification.name: "Java Virtual Machine Specification"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.vm.specification.vendor: "Oracle Corporation"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.vm.specification.version: "1.8"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.vm.vendor: "Oracle Corporation"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - java.vm.version: "25.181-b13"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - line.separator: "\n"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - os.arch: "amd64"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - os.name: "Linux"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - os.version: "4.15.0-66-generic"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - path.separator: ":"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.all: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.certpath: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.data: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.defaultctx: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.handshake: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.keygen: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.keymanager: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.ocsp: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.packet: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.plaintext: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.pluggability: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.record: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.session: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.sessioncache: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.ssl: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.sslctx: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.trustmanager: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.debug.verbose: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.default: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.disabledKeyAlgorithms: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1494
"RSA keySize < 2048",
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1494
"DSA keySize < 2048",
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1494
"EC keySize < 224"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.disabledSignatureAlgorithms: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1491
"MD2",
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1491
"MD4",
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1491
"MD5"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.enabledCipherSuites: []
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.enabledProtocols: [
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1488
"TLSv1.2",
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1488
"TLSv1.1",
# reference.conf @ jar:file:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar!/reference.conf: 1488
"TLSv1"
]
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.keyManager.stores: []
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.logger: "com.typesafe.sslconfig.akka.util.AkkaLoggerBridge"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.loose.acceptAnyCertificate: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.loose.allowWeakCiphers: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.loose.allowWeakProtocols: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.loose.disableHostnameVerification: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.loose.disableSNI: false
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.protocol: "TLSv1.2"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.revocationLists: []
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.sslParameters.clientAuth: "default"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.sslParameters.protocols: []
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - ssl-config.trustManager.stores: []
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - sun.arch.data.model: "64"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - sun.boot.class.path: "/usr/lib/jvm/java-8-openjdk-amd64/jre/lib/resources.jar:/usr/lib/jvm/java-8-openjdk-amd64/jre/lib/rt.jar:/usr/lib/jvm/java-8-openjdk-amd64/jre/lib/sunrsasign.jar:/usr/lib/jvm/java-8-openjdk-amd64/jre/lib/jsse.jar:/usr/lib/jvm/java-8-openjdk-amd64/jre/lib/jce.jar:/usr/lib/jvm/java-8-openjdk-amd64/jre/lib/charsets.jar:/usr/lib/jvm/java-8-openjdk-amd64/jre/lib/jfr.jar:/usr/lib/jvm/java-8-openjdk-amd64/jre/classes"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - sun.boot.library.path: "/usr/lib/jvm/java-8-openjdk-amd64/jre/lib/amd64"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - sun.cpu.endian: "little"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - sun.cpu.isalist: ""
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - sun.io.unicode.encoding: "UnicodeLittle"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - sun.java.command: "com.tesla.data.channel.KafkaRawToCanonical"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - sun.java.launcher: "SUN_STANDARD"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - sun.jnu.encoding: "UTF-8"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - sun.management.compiler: "HotSpot 64-Bit Tiered Compilers"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - sun.os.patch.level: "unknown"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - user.dir: "/opt/tesla/dataworks"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - user.home: "/root"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - user.language: "en"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - user.name: "root"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:25 - user.timezone: "Etc/UTC"
2020-07-15 17:53:23 INFO [main] c.t.d.c.KafkaRawToCanonical:125 - Starting 1 instances of KafkaRawToCanonical
2020-07-15 17:53:23 INFO [main] c.t.d.c.m.MetricsService:45 - Started metrics reporter
2020-07-15 17:53:23 INFO [PrometheusJmxReporterService STARTING] c.t.d.c.m.p.PrometheusJmxReporterService:44 - Started Prometheus JMX reporter
2020-07-15 17:53:23 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-2] c.t.d.c.KafkaRawToCanonical:92 - Starting channel
2020-07-15 17:53:23 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-4] o.a.k.c.p.ProducerConfig:347 - ProducerConfig values:
acks = 1
batch.size = 16384
bootstrap.servers = [kafka-brokers:9092]
buffer.memory = 33554432
client.dns.lookup = default
client.id = alpakka-bug.consumer.group
compression.type = lz4
connections.max.idle.ms = 540000
delivery.timeout.ms = 120000
enable.idempotence = false
interceptor.classes = []
key.serializer = class io.confluent.kafka.serializers.KafkaAvroSerializer
linger.ms = 50
max.block.ms = 60000
max.in.flight.requests.per.connection = 5
max.request.size = 1048576
metadata.max.age.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
receive.buffer.bytes = 32768
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retries = 2147483647
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.mechanism = GSSAPI
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.endpoint.identification.algorithm = https
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLS
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
transaction.timeout.ms = 60000
transactional.id = null
value.serializer = class io.confluent.kafka.serializers.KafkaAvroSerializer
2020-07-15 17:53:23 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-4] i.c.k.s.KafkaAvroSerializerConfig:179 - KafkaAvroSerializerConfig values:
schema.registry.url = [http://schema-registry.com]
basic.auth.user.info = [hidden]
auto.register.schemas = true
max.schemas.per.subject = 1000
basic.auth.credentials.source = URL
schema.registry.basic.auth.user.info = [hidden]
value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy
key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy
2020-07-15 17:53:24 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-4] i.c.k.s.KafkaAvroSerializerConfig:179 - KafkaAvroSerializerConfig values:
schema.registry.url = [http://schema-registry.com]
basic.auth.user.info = [hidden]
auto.register.schemas = true
max.schemas.per.subject = 1000
basic.auth.credentials.source = URL
schema.registry.basic.auth.user.info = [hidden]
value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy
key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy
2020-07-15 17:53:24 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-4] o.a.k.c.u.AppInfoParser:117 - Kafka version: 5.4.2-ccs
2020-07-15 17:53:24 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-4] o.a.k.c.u.AppInfoParser:118 - Kafka commitId: 444e12d6acc76f91
2020-07-15 17:53:24 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-4] o.a.k.c.u.AppInfoParser:119 - Kafka startTimeMs: 1594835604216
2020-07-15 17:53:24 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.SingleSourceLogic:92 - [bcad5] Starting. StageActor Actor[akka://KafkaRawToCanonical/system/StreamSupervisor-0/$$a#1673758833]
2020-07-15 17:53:24 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] CommitCollectorStage initialized
2020-07-15 17:53:24 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.KafkaConsumerActor:97 - [43d52] Starting Actor[akka://KafkaRawToCanonical/system/kafka-consumer-1#-308668790]
2020-07-15 17:53:24 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.KafkaConsumerActor:97 - [43d52] Creating Kafka consumer with akka.kafka.ConsumerSettings(properties=key.deserializer -> org.apache.kafka.common.serialization.ByteArrayDeserializer,auto.offset.reset -> latest,auto.register.schemas -> true,group.id -> alpakka-bug.consumer.group,bootstrap.servers -> kafka-brokers:9092,enable.auto.commit -> false,value.deserializer -> org.apache.kafka.common.serialization.ByteArrayDeserializer,max.poll.records -> 100,client.id -> alpakka-bug.consumer.group,schema.registry.url -> http://schema-registry.com,keyDeserializer=None,valueDeserializer=None,pollInterval=50 milliseconds,pollTimeout=50 milliseconds,stopTimeout=30 seconds,closeTimeout=20 seconds,commitTimeout=15 seconds,commitRefreshInterval=Duration.Inf,dispatcher=akka.kafka.default-dispatcher,commitTimeWarning=1 second,waitClosePartition=500 milliseconds,metadataRequestTimeout=5 seconds,drainingCheckInterval=30 milliseconds,connectionCheckerSettings=akka.kafka.ConnectionCheckerSettings(enable=false,maxRetries=3,checkInterval=15 seconds,factor=2.0),partitionHandlerWarning=5 secondsenrichAsync=None)
2020-07-15 17:53:24 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-5] o.a.k.c.c.ConsumerConfig:347 - ConsumerConfig values:
allow.auto.create.topics = true
auto.commit.interval.ms = 5000
auto.offset.reset = latest
bootstrap.servers = [kafka-brokers:9092]
check.crcs = true
client.dns.lookup = default
client.id = alpakka-bug.consumer.group
client.rack =
connections.max.idle.ms = 540000
default.api.timeout.ms = 60000
enable.auto.commit = false
exclude.internal.topics = true
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id = alpakka-bug.consumer.group
group.instance.id = null
heartbeat.interval.ms = 3000
interceptor.classes = []
internal.leave.group.on.close = true
isolation.level = read_uncommitted
key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
max.partition.fetch.bytes = 1048576
max.poll.interval.ms = 300000
max.poll.records = 100
metadata.max.age.ms = 300000
metric.reporters = []
metrics.num.samples = 2
metrics.recording.level = INFO
metrics.sample.window.ms = 30000
partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
receive.buffer.bytes = 65536
reconnect.backoff.max.ms = 1000
reconnect.backoff.ms = 50
request.timeout.ms = 30000
retry.backoff.ms = 100
sasl.client.callback.handler.class = null
sasl.jaas.config = null
sasl.kerberos.kinit.cmd = /usr/bin/kinit
sasl.kerberos.min.time.before.relogin = 60000
sasl.kerberos.service.name = null
sasl.kerberos.ticket.renew.jitter = 0.05
sasl.kerberos.ticket.renew.window.factor = 0.8
sasl.login.callback.handler.class = null
sasl.login.class = null
sasl.login.refresh.buffer.seconds = 300
sasl.login.refresh.min.period.seconds = 60
sasl.login.refresh.window.factor = 0.8
sasl.login.refresh.window.jitter = 0.05
sasl.mechanism = GSSAPI
security.protocol = PLAINTEXT
security.providers = null
send.buffer.bytes = 131072
session.timeout.ms = 10000
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.endpoint.identification.algorithm = https
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLS
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
2020-07-15 17:53:24 WARN [KafkaRawToCanonical-akka.kafka.default-dispatcher-5] o.a.k.c.c.ConsumerConfig:355 - The configuration 'schema.registry.url' was supplied but isn't a known config.
2020-07-15 17:53:24 WARN [KafkaRawToCanonical-akka.kafka.default-dispatcher-5] o.a.k.c.c.ConsumerConfig:355 - The configuration 'auto.register.schemas' was supplied but isn't a known config.
2020-07-15 17:53:24 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-5] o.a.k.c.u.AppInfoParser:117 - Kafka version: 5.4.2-ccs
2020-07-15 17:53:24 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-5] o.a.k.c.u.AppInfoParser:118 - Kafka commitId: 444e12d6acc76f91
2020-07-15 17:53:24 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-5] o.a.k.c.u.AppInfoParser:119 - Kafka startTimeMs: 1594835604993
2020-07-15 17:53:24 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-5] o.a.k.c.c.KafkaConsumer:969 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Subscribed to topic(s): REDACTED_topic_name
2020-07-15 17:53:25 INFO [kafka-producer-network-thread | alpakka-bug.consumer.group] o.a.k.c.Metadata:259 - [Producer clientId=alpakka-bug.consumer.group] Cluster ID: 6TchB8HIRgaGVzcFDBbGcA
2020-07-15 17:53:25 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-19] o.a.k.c.Metadata:259 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Cluster ID: 6TchB8HIRgaGVzcFDBbGcA
2020-07-15 17:53:25 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-20] o.a.k.c.c.i.AbstractCoordinator:756 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Discovered group coordinator REDACTED:9092 (id: 2147480438 rack: null)
2020-07-15 17:53:25 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-20] o.a.k.c.c.i.AbstractCoordinator:533 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] (Re-)joining group
2020-07-15 17:53:25 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.AbstractCoordinator:533 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] (Re-)joining group
2020-07-15 17:53:28 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.AbstractCoordinator:484 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Successfully joined group with generation 27719
2020-07-15 17:53:28 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.ConsumerCoordinator:267 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Adding newly assigned partitions: REDACTED_topic_name-455, REDACTED_topic_name-454, REDACTED_topic_name-453, REDACTED_topic_name-452, REDACTED_topic_name-451, REDACTED_topic_name-450, REDACTED_topic_name-449, REDACTED_topic_name-448, REDACTED_topic_name-447, REDACTED_topic_name-446, REDACTED_topic_name-445
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.SingleSourceLogic:97 - [bcad5] Assigned partitions: Set(REDACTED_topic_name-448, REDACTED_topic_name-446, REDACTED_topic_name-455, REDACTED_topic_name-445, REDACTED_topic_name-449, REDACTED_topic_name-454, REDACTED_topic_name-450, REDACTED_topic_name-453, REDACTED_topic_name-447, REDACTED_topic_name-452, REDACTED_topic_name-451). All partitions: Set(REDACTED_topic_name-448, REDACTED_topic_name-446, REDACTED_topic_name-455, REDACTED_topic_name-445, REDACTED_topic_name-449, REDACTED_topic_name-454, REDACTED_topic_name-450, REDACTED_topic_name-453, REDACTED_topic_name-447, REDACTED_topic_name-452, REDACTED_topic_name-451)
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.SingleSourceLogic:97 - [bcad5] Requesting messages, requestId: 1, partitions: Set(REDACTED_topic_name-448, REDACTED_topic_name-446, REDACTED_topic_name-455, REDACTED_topic_name-445, REDACTED_topic_name-449, REDACTED_topic_name-454, REDACTED_topic_name-450, REDACTED_topic_name-453, REDACTED_topic_name-447, REDACTED_topic_name-452, REDACTED_topic_name-451)
2020-07-15 17:53:28 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-455 to the committed offset FetchPosition{offset=4828694, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3053 rack: /RACK), epoch=-1}}
2020-07-15 17:53:28 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-454 to the committed offset FetchPosition{offset=4831032, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3058 rack: /RACK), epoch=-1}}
2020-07-15 17:53:28 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-453 to the committed offset FetchPosition{offset=4831647, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3055 rack: /RACK), epoch=-1}}
2020-07-15 17:53:28 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-452 to the committed offset FetchPosition{offset=4834016, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3063 rack: /RACK), epoch=-1}}
2020-07-15 17:53:28 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-451 to the committed offset FetchPosition{offset=4831478, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3061 rack: /RACK), epoch=-1}}
2020-07-15 17:53:28 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-450 to the committed offset FetchPosition{offset=4834094, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3190 rack: /RACK), epoch=-1}}
2020-07-15 17:53:28 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-449 to the committed offset FetchPosition{offset=4830217, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3057 rack: /RACK), epoch=-1}}
2020-07-15 17:53:28 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-448 to the committed offset FetchPosition{offset=4833636, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3065 rack: /RACK), epoch=-1}}
2020-07-15 17:53:28 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-447 to the committed offset FetchPosition{offset=4831095, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3048 rack: /RACK), epoch=-1}}
2020-07-15 17:53:28 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-446 to the committed offset FetchPosition{offset=4834199, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3054 rack: /RACK), epoch=-1}}
2020-07-15 17:53:28 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-445 to the committed offset FetchPosition{offset=4831820, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3050 rack: /RACK), epoch=-1}}
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [576ba] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [07a4d] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [576ba] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [07a4d] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [07a4d] Resume demand
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [576ba] Resume demand
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [20282] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [20282] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [20282] Resume demand
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.SingleSourceLogic:97 - [bcad5] Requesting messages, requestId: 2, partitions: Set(REDACTED_topic_name-448, REDACTED_topic_name-446, REDACTED_topic_name-455, REDACTED_topic_name-445, REDACTED_topic_name-449, REDACTED_topic_name-454, REDACTED_topic_name-450, REDACTED_topic_name-453, REDACTED_topic_name-447, REDACTED_topic_name-452, REDACTED_topic_name-451)
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.DefaultProducerStage:97 - [44b01] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.DefaultProducerStage:97 - [aeec1] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.DefaultProducerStage:97 - [b54f5] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:28 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.DefaultProducerStage:97 - [8b50d] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
log4j:WARN No appenders could be found for logger (org.apache.hadoop.security.Groups).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:zookeeper.version=3.4.5-cdh5.15.0--1, built on 05/24/2018 03:18 GMT
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:host.name=REDACTED-74c5c76896ztk25
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:java.version=1.8.0_181
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:java.vendor=Oracle Corporation
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:java.home=/usr/lib/jvm/java-8-openjdk-amd64/jre
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:java.class.path=/opt/tesla/dataworks/conf:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/akka_overrides.jar:/opt/tesla/dataworks/lib/dataworks-akka/src/main/scala/com/tesla/data/channel/all_in_one_deploy.jar:/opt/tesla/dataworks/lib/pipeline-car-can/src/main/java/com/tesla/data/pipeline/car/can/all_in_one_deploy.jar:/opt/tesla/dataworks/lib/pipeline-car-can/src/main/resources/schemas/libcanonical_jar.jar::/opt/tesla/java-agent/jmx_prometheus_javaagent.jar
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:java.io.tmpdir=/tmp
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:java.compiler=<NA>
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:os.name=Linux
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:os.arch=amd64
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:os.version=4.15.0-66-generic
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:user.name=root
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:user.home=/root
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:100 - Client environment:user.dir=/opt/tesla/dataworks
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.h.h.s.o.a.z.ZooKeeper:438 - Initiating client connection, connectString=n0219.hw.data.tesla:2181,n0579.hw.data.tesla:2181,n0592.hw.data.tesla:2181 sessionTimeout=90000 watcher=hconnection-0x74f2cb720x0, quorum=n0219.hw.data.tesla:2181,n0579.hw.data.tesla:2181,n0592.hw.data.tesla:2181, baseZNode=/hbase
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3-SendThread(n0219.hw.data.tesla:2181)] o.a.h.h.s.o.a.z.ClientCnxn:975 - Opening socket connection to server n0219.hw.data.tesla/REDACTED:2181. Will not attempt to authenticate using SASL (unknown error)
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3-SendThread(n0219.hw.data.tesla:2181)] o.a.h.h.s.o.a.z.ClientCnxn:852 - Socket connection established, initiating session, client: /10.233.73.70:40326, server: n0219.hw.data.tesla/REDACTED:2181
2020-07-15 17:53:29 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3-SendThread(n0219.hw.data.tesla:2181)] o.a.h.h.s.o.a.z.ClientCnxn:1235 - Session establishment complete on server n0219.hw.data.tesla/REDACTED:2181, sessionid = 0x66cdf5013098f5b, negotiated timeout = 90000
2020-07-15 17:53:31 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.AbstractCoordinator:984 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Attempt to heartbeat failed since group is rebalancing
2020-07-15 17:53:31 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.ConsumerCoordinator:286 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Revoke previously assigned partitions REDACTED_topic_name-455, REDACTED_topic_name-454, REDACTED_topic_name-453, REDACTED_topic_name-452, REDACTED_topic_name-451, REDACTED_topic_name-450, REDACTED_topic_name-449, REDACTED_topic_name-448, REDACTED_topic_name-447, REDACTED_topic_name-446, REDACTED_topic_name-445
2020-07-15 17:53:31 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-10] o.a.k.c.c.i.AbstractCoordinator:533 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] (Re-)joining group
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [1070d] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [0398c] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [66f93] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [b54f5] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [b54f5] Resume demand
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [8b50d] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [8b50d] Resume demand
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.SingleSourceLogic:97 - [bcad5] Requesting messages, requestId: 3, partitions: Set(REDACTED_topic_name-448, REDACTED_topic_name-446, REDACTED_topic_name-455, REDACTED_topic_name-445, REDACTED_topic_name-449, REDACTED_topic_name-454, REDACTED_topic_name-450, REDACTED_topic_name-453, REDACTED_topic_name-447, REDACTED_topic_name-452, REDACTED_topic_name-451)
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [1070d] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [1070d] Resume demand
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.SingleSourceLogic:97 - [bcad5] Revoked partitions: Set(REDACTED_topic_name-448, REDACTED_topic_name-446, REDACTED_topic_name-455, REDACTED_topic_name-445, REDACTED_topic_name-449, REDACTED_topic_name-454, REDACTED_topic_name-450, REDACTED_topic_name-453, REDACTED_topic_name-447, REDACTED_topic_name-452, REDACTED_topic_name-451). All partitions: Set()
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [aeec1] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [aeec1] Resume demand
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [0398c] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [0398c] Resume demand
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [66f93] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [66f93] Resume demand
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [44b01] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:32 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [44b01] Resume demand
2020-07-15 17:53:33 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.AbstractCoordinator:484 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Successfully joined group with generation 27720
2020-07-15 17:53:33 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.ConsumerCoordinator:267 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Adding newly assigned partitions: REDACTED_topic_name-451, REDACTED_topic_name-450, REDACTED_topic_name-449, REDACTED_topic_name-448, REDACTED_topic_name-447, REDACTED_topic_name-446
2020-07-15 17:53:33 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-448 to the committed offset FetchPosition{offset=4833636, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3065 rack: /RACK), epoch=-1}}
2020-07-15 17:53:33 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-447 to the committed offset FetchPosition{offset=4831095, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3048 rack: /RACK), epoch=-1}}
2020-07-15 17:53:33 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-446 to the committed offset FetchPosition{offset=4834199, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3054 rack: /RACK), epoch=-1}}
2020-07-15 17:53:33 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-451 to the committed offset FetchPosition{offset=4831478, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3061 rack: /RACK), epoch=-1}}
2020-07-15 17:53:33 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-450 to the committed offset FetchPosition{offset=4834094, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3190 rack: /RACK), epoch=-1}}
2020-07-15 17:53:33 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-449 to the committed offset FetchPosition{offset=4830217, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3057 rack: /RACK), epoch=-1}}
2020-07-15 17:53:33 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.SingleSourceLogic:97 - [bcad5] filtering out messages from revoked partitions Set(REDACTED_topic_name-455, REDACTED_topic_name-445, REDACTED_topic_name-454, REDACTED_topic_name-453, REDACTED_topic_name-452)
2020-07-15 17:53:33 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.SingleSourceLogic:97 - [bcad5] Assigned partitions: Set(REDACTED_topic_name-448, REDACTED_topic_name-446, REDACTED_topic_name-449, REDACTED_topic_name-450, REDACTED_topic_name-447, REDACTED_topic_name-451). All partitions: Set(REDACTED_topic_name-448, REDACTED_topic_name-446, REDACTED_topic_name-449, REDACTED_topic_name-450, REDACTED_topic_name-447, REDACTED_topic_name-451)
2020-07-15 17:53:33 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.SingleSourceLogic:97 - [bcad5] Requesting messages, requestId: 4, partitions: Set(REDACTED_topic_name-448, REDACTED_topic_name-446, REDACTED_topic_name-449, REDACTED_topic_name-450, REDACTED_topic_name-447, REDACTED_topic_name-451)
2020-07-15 17:53:33 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.SingleSourceLogic:97 - [bcad5] filtering out messages from revoked partitions Set(REDACTED_topic_name-455, REDACTED_topic_name-445, REDACTED_topic_name-454, REDACTED_topic_name-453, REDACTED_topic_name-452)
2020-07-15 17:53:33 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:35 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [aeec1] ProducerStage postStop
2020-07-15 17:53:35 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [44b01] ProducerStage postStop
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [66f93] ProducerStage postStop
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [0398c] ProducerStage postStop
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.DefaultProducerStage:97 - [07a4d] ProducerStage postStop
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831820),)
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [8b50d] ProducerStage postStop
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [a6218] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [a6218] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [a6218] Resume demand
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [1070d] ProducerStage postStop
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.DefaultProducerStage:97 - [576ba] ProducerStage postStop
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831821),)
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.DefaultProducerStage:97 - [dd8fc] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.DefaultProducerStage:97 - [dd8fc] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.DefaultProducerStage:97 - [dd8fc] Resume demand
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [b54f5] ProducerStage postStop
2020-07-15 17:53:36 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-20] o.a.k.c.c.i.AbstractCoordinator:984 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Attempt to heartbeat failed since group is rebalancing
2020-07-15 17:53:36 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-18] o.a.k.c.c.i.ConsumerCoordinator:286 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Revoke previously assigned partitions REDACTED_topic_name-451, REDACTED_topic_name-450, REDACTED_topic_name-449, REDACTED_topic_name-448, REDACTED_topic_name-447, REDACTED_topic_name-446
2020-07-15 17:53:36 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-18] o.a.k.c.c.i.AbstractCoordinator:533 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] (Re-)joining group
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.SingleSourceLogic:97 - [bcad5] Revoked partitions: Set(REDACTED_topic_name-448, REDACTED_topic_name-446, REDACTED_topic_name-449, REDACTED_topic_name-450, REDACTED_topic_name-447, REDACTED_topic_name-451). All partitions: Set()
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] pushDownStream triggered by interval, outstanding batch CommittableOffsetBatch(batchSize=2, GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445) -> 4831821)
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [20282] ProducerStage postStop
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831822),)
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831823),)
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831824),)
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [7bd7e] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [7bd7e] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [7bd7e] Resume demand
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831825),)
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [37b0e] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [37b0e] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [37b0e] Resume demand
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831826),)
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [097c1] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:36 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [dd8fc] ProducerStage postStop
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [097c1] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [097c1] Resume demand
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831827),)
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [5a3a6] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831828),)
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831829),)
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [1ed12] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [39f4c] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [39f4c] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [39f4c] Resume demand
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [957cf] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [e2731] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [1ed12] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [1ed12] Resume demand
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [957cf] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [957cf] Resume demand
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [e2731] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [e2731] Resume demand
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [5a3a6] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:37 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [5a3a6] Resume demand
2020-07-15 17:53:38 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [a6218] ProducerStage postStop
2020-07-15 17:53:38 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831830),)
2020-07-15 17:53:38 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831831),)
2020-07-15 17:53:38 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:38 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:38 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [644b6] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:38 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [644b6] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:38 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [644b6] Resume demand
2020-07-15 17:53:38 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-17] o.a.k.c.c.i.AbstractCoordinator:533 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] (Re-)joining group
2020-07-15 17:53:38 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [0d61e] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:38 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [0d61e] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:38 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [0d61e] Resume demand
2020-07-15 17:53:39 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [e2731] ProducerStage postStop
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [37b0e] ProducerStage postStop
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [097c1] ProducerStage postStop
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [1ed12] ProducerStage postStop
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [7bd7e] ProducerStage postStop
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831832),)
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831833),)
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831834),)
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [f634b] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [f634b] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [f634b] Resume demand
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [1b50f] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [1b50f] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [1b50f] Resume demand
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [fdd4b] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [fdd4b] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [fdd4b] Resume demand
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [0d61e] ProducerStage postStop
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [957cf] ProducerStage postStop
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [39f4c] ProducerStage postStop
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [644b6] ProducerStage postStop
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.DefaultProducerStage:97 - [5a3a6] ProducerStage postStop
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831835),)
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445),offset=4831836),)
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,449),offset=4830217),)
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [b60b0] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [b60b0] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [b60b0] Resume demand
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,449),offset=4830218),)
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [7922c] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [7922c] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [7922c] Resume demand
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [dc0cd] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,449),offset=4830219),)
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [dc0cd] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [dc0cd] Resume demand
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,449),offset=4830220),)
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] Consuming offset CommittableOffsetImpl(PartitionOffset(key=GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,449),offset=4830221),)
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.s.i.fusing.Buffer:97 - Backpressuring because buffer is full and overflowStrategy is: [Backpressure]
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [ba1f9] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [ffa14] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [ed5fa] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [ed5fa] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [ed5fa] Resume demand
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [531fa] Asynchronous producer assignment lifecycle changed 'Unassigned -> AsyncCreateRequestSent'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [ffa14] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [ffa14] Resume demand
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [ba1f9] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [ba1f9] Resume demand
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [531fa] Asynchronous producer assignment lifecycle changed 'AsyncCreateRequestSent -> Assigned'
2020-07-15 17:53:40 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.DefaultProducerStage:97 - [531fa] Resume demand
2020-07-15 17:53:41 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] pushDownStream triggered by interval, outstanding batch CommittableOffsetBatch(batchSize=20, GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,445) -> 4831836, GroupTopicPartition(alpakka-bug.consumer.group,REDACTED_topic_name,449) -> 4830221)
2020-07-15 17:53:41 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.CommitCollectorStageLogic:97 - [8bd7c] CommitCollectorStage stopped
2020-07-15 17:53:41 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.SingleSourceLogic:92 - [bcad5] Completing
2020-07-15 17:53:42 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [7922c] ProducerStage postStop
2020-07-15 17:53:42 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [fdd4b] ProducerStage postStop
2020-07-15 17:53:42 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.DefaultProducerStage:97 - [ba1f9] ProducerStage postStop
2020-07-15 17:53:42 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [ed5fa] ProducerStage postStop
2020-07-15 17:53:42 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [b60b0] ProducerStage postStop
2020-07-15 17:53:42 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [ffa14] ProducerStage postStop
2020-07-15 17:53:42 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [f634b] ProducerStage postStop
2020-07-15 17:53:42 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-3] a.k.i.DefaultProducerStage:97 - [1b50f] ProducerStage postStop
2020-07-15 17:53:42 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-4] a.k.i.DefaultProducerStage:97 - [dc0cd] ProducerStage postStop
2020-07-15 17:53:42 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.DefaultProducerStage:97 - [531fa] ProducerStage postStop
2020-07-15 17:53:43 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.AbstractCoordinator:484 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Successfully joined group with generation 27722
2020-07-15 17:53:43 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.ConsumerCoordinator:267 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Adding newly assigned partitions: REDACTED_topic_name-433, REDACTED_topic_name-432
2020-07-15 17:53:43 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.SingleSourceLogic:97 - [bcad5] filtering out messages from revoked partitions Set(REDACTED_topic_name-448, REDACTED_topic_name-446, REDACTED_topic_name-449, REDACTED_topic_name-450, REDACTED_topic_name-447, REDACTED_topic_name-451)
2020-07-15 17:53:43 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.SingleSourceLogic:97 - [bcad5] Assigned partitions: Set(REDACTED_topic_name-433, REDACTED_topic_name-432). All partitions: Set(REDACTED_topic_name-432, REDACTED_topic_name-433)
2020-07-15 17:53:43 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.SingleSourceLogic:97 - [bcad5] Requesting messages, requestId: 5, partitions: Set(REDACTED_topic_name-432, REDACTED_topic_name-433)
2020-07-15 17:53:43 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-21] a.k.i.SingleSourceLogic:97 - [bcad5] filtering out messages from revoked partitions Set(REDACTED_topic_name-448, REDACTED_topic_name-446, REDACTED_topic_name-449, REDACTED_topic_name-450, REDACTED_topic_name-447, REDACTED_topic_name-451)
2020-07-15 17:53:43 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-432 to the committed offset FetchPosition{offset=4831214, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3188 rack: /RACK), epoch=-1}}
2020-07-15 17:53:43 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-16] o.a.k.c.c.i.ConsumerCoordinator:765 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Setting offset for partition REDACTED_topic_name-433 to the committed offset FetchPosition{offset=4832044, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=REDACTED:9092 (id: 3070 rack: /RACK), epoch=-1}}
2020-07-15 17:53:43 DEBUG [KafkaRawToCanonical-akka.actor.default-dispatcher-2] a.k.i.KafkaConsumerActor:97 - [43d52] Received Stop from StageId [bcad5], stopping
2020-07-15 17:53:43 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-2] c.t.d.c.KafkaRawToCanonical:92 - Stream has stopped, killing myself (the wrapping actor) as well
2020-07-15 17:53:43 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-4] c.t.d.c.KafkaRawToCanonical:92 - Closing com.tesla.data.channel.common.ChannelActor$$anon$2@6bb7f08f
2020-07-15 17:53:43 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-4] c.t.d.c.KafkaRawToCanonical:92 - Closing org.apache.kafka.clients.producer.KafkaProducer@a6266c8
2020-07-15 17:53:43 WARN [KafkaRawToCanonical-akka.actor.default-dispatcher-4] c.t.d.c.KafkaRawToCanonical:86 - Stream finished, we do not expect it to finish. Did some stage stop?
2020-07-15 17:53:43 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-12] o.a.k.c.c.i.ConsumerCoordinator:286 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Revoke previously assigned partitions REDACTED_topic_name-433, REDACTED_topic_name-432
2020-07-15 17:53:43 INFO [KafkaRawToCanonical-akka.kafka.default-dispatcher-12] o.a.k.c.c.i.AbstractCoordinator:916 - [Consumer clientId=alpakka-bug.consumer.group, groupId=alpakka-bug.consumer.group] Member alpakka-bug.consumer.group-db648b47-494b-4028-b66d-012e12ab6081 sending LeaveGroup request to coordinator REDACTED:9092 (id: 2147480438 rack: null) due to the consumer is being closed
2020-07-15 17:53:43 INFO [KafkaRawToCanonical-akka.actor.default-dispatcher-3] o.a.k.c.p.KafkaProducer:1183 - [Producer clientId=alpakka-bug.consumer.group] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment