You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by François Langelier <f....@gmail.com> on 2014/06/10 21:45:23 UTC
spam of [kafka-processor-9092-0] INFO kafka.network.Processor -
Closing socket connection to /172.23.44.4.
Hi all!
I have 3 brokers and I keep getting this message:
[kafka-processor-9092-0] INFO kafka.network.Processor - Closing socket
connection to /172.23.44.4.
or
[kafka-processor-9092-1] INFO kafka.network.Processor - Closing socket
connection to /172.23.44.4.
Do anyone know what that means???
(By the way, the IP isn't something in my network...)
I'm using kafka 0.8.1.1 with scala 2.9.2
thank for your help!
Here is my log:
[2014-06-10 18:43:58,332] 612950 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
> [TopicChangeListener on Controller 1]: New topics:
> [Set(REG_USER_TRACKING_LOG)], deleted topics: [Set()], new partition
> replica assignment [Map([REG_USER_TRACKING_LOG,0] -> List(1, 3, 2))]
> [2014-06-10 18:43:58,333] 612951 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.KafkaController - [Controller 1]: New topic
> creation callback for [REG_USER_TRACKING_LOG,0]
> [2014-06-10 18:43:58,336] 612954 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.KafkaController - [Controller 1]: New partition
> creation callback for [REG_USER_TRACKING_LOG,0]
> [2014-06-10 18:43:58,337] 612955 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.PartitionStateMachine - [Partition state machine on
> Controller 1]: Invoking state change to NewPartition for partitions
> [REG_USER_TRACKING_LOG,0]
> [2014-06-10 18:43:58,347] 612965 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> controller 1]: Invoking state change to NewReplica for replicas
> [Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=1],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=3],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=2]
> [2014-06-10 18:43:58,352] 612970 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.PartitionStateMachine - [Partition state machine on
> Controller 1]: Invoking state change to OnlinePartition for partitions
> [REG_USER_TRACKING_LOG,0]
> [2014-06-10 18:43:58,470] 613088 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> controller 1]: Invoking state change to OnlineReplica for replicas
> [Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=1],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=3],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=2]
> [2014-06-10 18:43:58,478] 613096 [kafka-request-handler-1] INFO
> kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 1]
> Removed fetcher for partitions [REG_USER_TRACKING_LOG,0]
> [2014-06-10 18:43:58,533] 613151 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:43:58,538] 613156 [kafka-request-handler-1] INFO
> kafka.log.Log - Completed load of log REG_USER_TRACKING_LOG-0 with log
> end offset 0
> [2014-06-10 18:43:58,546] 613164 [kafka-request-handler-1] INFO
> kafka.log.LogManager - Created log for partition
> [REG_USER_TRACKING_LOG,0] in /var/spool/kafka with properties
> {segment.index.bytes -> 10485760, file.delete.delay.ms -> 60000,
> segment.bytes -> 536870912, flush.ms -> 9223372036854775807,
> delete.retention.ms -> 86400000, index.interval.bytes -> 4096,
> retention.bytes -> -1, cleanup.policy -> delete, segment.ms -> 604800000,
> max.message.bytes -> 1000012, flush.messages -> 9223372036854775807,
> min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
> [2014-06-10 18:43:58,547] 613165 [kafka-request-handler-1] WARN
> kafka.cluster.Partition - Partition [REG_USER_TRACKING_LOG,0] on broker
> 1: No checkpointed highwatermark is found for partition
> [REG_USER_TRACKING_LOG,0]
> [2014-06-10 18:43:59,372] 613990 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:43:59,577] 614195 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:43:59,782] 614400 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:43:59,988] 614606 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:00,622] 615240 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:01,033] 615651 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:01,115] 615733 [kafka-request-handler-3] INFO
> kafka.admin.AdminUtils$ - Topic creation
> {"version":1,"partitions":{"0":[3,1,2]}}
> [2014-06-10 18:44:01,140] 615758 [kafka-request-handler-3] INFO
> kafka.server.KafkaApis - [KafkaApi-1] Auto creation of topic
> RULE_RECRIMINATION with 1 partitions and replication factor 3 is successful!
> [2014-06-10 18:44:01,141] 615759 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:01,150] 615768 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
> [TopicChangeListener on Controller 1]: New topics:
> [Set(RULE_RECRIMINATION)], deleted topics: [Set()], new partition replica
> assignment [Map([RULE_RECRIMINATION,0] -> List(3, 1, 2))]
> [2014-06-10 18:44:01,150] 615768 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.KafkaController - [Controller 1]: New topic
> creation callback for [RULE_RECRIMINATION,0]
> [2014-06-10 18:44:01,151] 615769 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.KafkaController - [Controller 1]: New partition
> creation callback for [RULE_RECRIMINATION,0]
> [2014-06-10 18:44:01,151] 615769 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.PartitionStateMachine - [Partition state machine on
> Controller 1]: Invoking state change to NewPartition for partitions
> [RULE_RECRIMINATION,0]
> [2014-06-10 18:44:01,157] 615775 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> controller 1]: Invoking state change to NewReplica for replicas
> [Topic=RULE_RECRIMINATION,Partition=0,Replica=3],[Topic=RULE_RECRIMINATION,Partition=0,Replica=1],[Topic=RULE_RECRIMINATION,Partition=0,Replica=2]
> [2014-06-10 18:44:01,159] 615777 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.PartitionStateMachine - [Partition state machine on
> Controller 1]: Invoking state change to OnlinePartition for partitions
> [RULE_RECRIMINATION,0]
> [2014-06-10 18:44:01,223] 615841 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> controller 1]: Invoking state change to OnlineReplica for replicas
> [Topic=RULE_RECRIMINATION,Partition=0,Replica=3],[Topic=RULE_RECRIMINATION,Partition=0,Replica=1],[Topic=RULE_RECRIMINATION,Partition=0,Replica=2]
> [2014-06-10 18:44:01,231] 615849 [kafka-request-handler-6] INFO
> kafka.log.Log - Completed load of log RULE_RECRIMINATION-0 with log end
> offset 0
> [2014-06-10 18:44:01,232] 615850 [kafka-request-handler-6] INFO
> kafka.log.LogManager - Created log for partition [RULE_RECRIMINATION,0]
> in /var/spool/kafka with properties {segment.index.bytes -> 10485760,
> file.delete.delay.ms -> 60000, segment.bytes -> 536870912, flush.ms ->
> 9223372036854775807, delete.retention.ms -> 86400000,
> index.interval.bytes -> 4096, retention.bytes -> -1, cleanup.policy ->
> delete, segment.ms -> 604800000, max.message.bytes -> 1000012,
> flush.messages -> 9223372036854775807, min.cleanable.dirty.ratio -> 0.5,
> retention.ms -> 604800000}.
> [2014-06-10 18:44:01,233] 615851 [kafka-request-handler-6] WARN
> kafka.cluster.Partition - Partition [RULE_RECRIMINATION,0] on broker 1:
> No checkpointed highwatermark is found for partition [RULE_RECRIMINATION,0]
> [2014-06-10 18:44:01,235] 615853 [kafka-request-handler-6] INFO
> kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 1]
> Removed fetcher for partitions [RULE_RECRIMINATION,0]
> [2014-06-10 18:44:01,238] 615856 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:01,239] 615857 [kafka-request-handler-6] INFO
> kafka.log.Log - Truncating log RULE_RECRIMINATION-0 to offset 0.
> [2014-06-10 18:44:01,265] 615883 [ReplicaFetcherThread-0-3] INFO
> kafka.server.ReplicaFetcherThread - [ReplicaFetcherThread-0-3], Starting
> [2014-06-10 18:44:01,270] 615888 [kafka-request-handler-6] INFO
> kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 1]
> Added fetcher for partitions ArrayBuffer([[RULE_RECRIMINATION,0],
> initOffset 0 to broker id:3,host:kaf3,port:9092] )
> [2014-06-10 18:44:01,344] 615962 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:01,354] 615972 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:01,549] 616167 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:01,649] 616267 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:01,986] 616604 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:02,470] 617088 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:02,610] 617228 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:02,818] 617436 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:03,025] 617643 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:03,194] 617812 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:03,233] 617851 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:03,649] 618267 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:04,015] 618633 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:04,064] 618682 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:04,272] 618890 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:04,480] 619098 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:04,526] 619144 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:04,634] 619252 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:04,731] 619349 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:04,936] 619554 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:05,141] 619759 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:05,308] 619926 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:05,346] 619964 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:05,456] 620074 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:05,516] 620134 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:05,723] 620341 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:06,687] 621305 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:07,175] 621793 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:07,381] 621999 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:07,397] 622015 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:07,796] 622414 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:08,217] 622835 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:08,328] 622946 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:09,041] 623659 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:09,152] 623770 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:10,074] 624692 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:10,176] 624794 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:10,380] 624998 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:10,488] 625106 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:10,585] 625203 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:10,694] 625312 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:10,790] 625408 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:11,200] 625818 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:11,613] 626231 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:11,731] 626349 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:58,282] 672900 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
> [TopicChangeListener on Controller 1]: New topics:
> [Set(KAFKA_LOGGING_MESSAGE)], deleted topics: [Set()], new partition
> replica assignment [Map([KAFKA_LOGGING_MESSAGE,0] -> List(3, 1, 2))]
> [2014-06-10 18:44:58,282] 672900 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.KafkaController - [Controller 1]: New topic
> creation callback for [KAFKA_LOGGING_MESSAGE,0]
> [2014-06-10 18:44:58,283] 672901 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.KafkaController - [Controller 1]: New partition
> creation callback for [KAFKA_LOGGING_MESSAGE,0]
> [2014-06-10 18:44:58,283] 672901 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.PartitionStateMachine - [Partition state machine on
> Controller 1]: Invoking state change to NewPartition for partitions
> [KAFKA_LOGGING_MESSAGE,0]
> [2014-06-10 18:44:58,287] 672905 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:58,287] 672905 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> controller 1]: Invoking state change to NewReplica for replicas
> [Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=3],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=1],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=2]
> [2014-06-10 18:44:58,292] 672910 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.PartitionStateMachine - [Partition state machine on
> Controller 1]: Invoking state change to OnlinePartition for partitions
> [KAFKA_LOGGING_MESSAGE,0]
> [2014-06-10 18:44:58,351] 672969 [
> ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> controller 1]: Invoking state change to OnlineReplica for replicas
> [Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=3],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=1],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=2]
> [2014-06-10 18:44:58,362] 672980 [kafka-request-handler-1] INFO
> kafka.log.Log - Completed load of log KAFKA_LOGGING_MESSAGE-0 with log
> end offset 0
> [2014-06-10 18:44:58,367] 672985 [kafka-request-handler-1] INFO
> kafka.log.LogManager - Created log for partition
> [KAFKA_LOGGING_MESSAGE,0] in /var/spool/kafka with properties
> {segment.index.bytes -> 10485760, file.delete.delay.ms -> 60000,
> segment.bytes -> 536870912, flush.ms -> 9223372036854775807,
> delete.retention.ms -> 86400000, index.interval.bytes -> 4096,
> retention.bytes -> -1, cleanup.policy -> delete, segment.ms -> 604800000,
> max.message.bytes -> 1000012, flush.messages -> 9223372036854775807,
> min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
> [2014-06-10 18:44:58,374] 672992 [kafka-request-handler-1] WARN
> kafka.cluster.Partition - Partition [KAFKA_LOGGING_MESSAGE,0] on broker
> 1: No checkpointed highwatermark is found for partition
> [KAFKA_LOGGING_MESSAGE,0]
> [2014-06-10 18:44:58,375] 672993 [kafka-request-handler-1] INFO
> kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 1]
> Removed fetcher for partitions [KAFKA_LOGGING_MESSAGE,0]
> [2014-06-10 18:44:58,376] 672994 [kafka-request-handler-1] INFO
> kafka.log.Log - Truncating log KAFKA_LOGGING_MESSAGE-0 to offset 0.
> [2014-06-10 18:44:58,377] 672995 [kafka-request-handler-1] INFO
> kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 1]
> Added fetcher for partitions ArrayBuffer([[KAFKA_LOGGING_MESSAGE,0],
> initOffset 0 to broker id:3,host:kaf3,port:9092] )
> [2014-06-10 18:44:58,706] 673324 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:58,911] 673529 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:59,116] 673734 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:59,321] 673939 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:59,526] 674144 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:44:59,938] 674556 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:00,143] 674761 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:00,554] 675172 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:01,171] 675789 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:01,581] 676199 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:01,934] 676552 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:02,345] 676963 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:02,550] 677168 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:02,756] 677374 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:03,434] 678052 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:03,988] 678606 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:04,464] 679082 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:04,605] 679223 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:04,670] 679288 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:05,226] 679844 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:05,491] 680109 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:06,048] 680666 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:06,254] 680872 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:06,459] 681077 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:06,518] 681136 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:07,485] 682103 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:07,690] 682308 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:07,955] 682573 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:08,101] 682719 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:08,570] 683188 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:08,722] 683340 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:09,139] 683757 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:09,345] 683963 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:09,550] 684168 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:10,989] 685607 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:11,401] 686019 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:45:11,605] 686223 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:04,680] 1099298 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:05,090] 1099708 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:05,704] 1100322 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:05,909] 1100527 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:06,935] 1101553 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:07,455] 1102073 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:07,998] 1102616 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:08,163] 1102781 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:08,411] 1103029 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:08,823] 1103441 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:09,030] 1103648 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:09,089] 1103707 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:09,236] 1103854 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:09,391] 1104009 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:09,442] 1104060 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:09,595] 1104213 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:09,903] 1104521 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:10,061] 1104679 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:10,266] 1104884 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:10,311] 1104929 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:10,416] 1105034 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:10,620] 1105238 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:10,884] 1105502 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:11,296] 1105914 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:11,741] 1106359 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:11,945] 1106563 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:12,051] 1106669 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:12,324] 1106942 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:12,459] 1107077 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:12,529] 1107147 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:12,736] 1107354 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:12,941] 1107559 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:13,147] 1107765 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:13,375] 1107993 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:13,481] 1108099 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:13,559] 1108177 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:13,579] 1108197 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:13,686] 1108304 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:13,764] 1108382 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:13,782] 1108400 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:14,176] 1108794 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:14,191] 1108809 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:14,793] 1109411 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:15,204] 1109822 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:15,211] 1109829 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:15,823] 1110441 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:16,029] 1110647 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:16,645] 1111263 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:16,850] 1111468 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:17,053] 1111671 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:54,009] 1148627 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:55,440] 1150058 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:56,054] 1150672 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:56,258] 1150876 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:56,668] 1151286 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:57,445] 1152063 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:57,853] 1152471 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:58,261] 1152879 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:58,466] 1153084 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:58,670] 1153288 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:58,711] 1153329 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:59,283] 1153901 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:52:59,488] 1154106 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:00,100] 1154718 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:01,165] 1155783 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:01,325] 1155943 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:01,369] 1155987 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:01,778] 1156396 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:02,187] 1156805 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:02,550] 1157168 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:02,594] 1157212 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:02,958] 1157576 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:03,367] 1157985 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:03,616] 1158234 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:03,979] 1158597 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:04,388] 1159006 [kafka-processor-9092-0] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
> [2014-06-10 18:53:04,796] 1159414 [kafka-processor-9092-1] INFO
> kafka.network.Processor - Closing socket connection to /172.23.44.4.
François Langelier
Étudiant en génie Logiciel - École de Technologie Supérieure
<http://www.etsmtl.ca/>
Capitaine Club Capra <http://capra.etsmtl.ca/>
VP-Communication - CS Games <http://csgames.org> 2014
Jeux de Génie <http://www.jdgets.com/> 2011 à 2014
Argentier Fraternité du Piranha <http://fraternitedupiranha.com/> 2012-2014
Comité Organisateur Olympiades ÉTS 2012
Compétition Québécoise d'Ingénierie 2012 - Compétition Senior
Re: spam of [kafka-processor-9092-0] INFO kafka.network.Processor -
Closing socket connection to /172.23.44.4.
Posted by Jun Rao <ju...@gmail.com>.
You may want to take a look at
https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-Whycan'tmyconsumers/producersconnecttothebrokers
?
Thanks,
Jun
On Wed, Jun 11, 2014 at 12:12 PM, François Langelier <f....@gmail.com>
wrote:
> FYI, I found out what was wrong and I think it's a wierd behaviour that you
> guys may want to fix...
>
> First of all, my setup is the following
> I have 3 brokers named :
> kaf1.kafka.mydns -> 50.50.50.51
> kaf2.kafka.mydns -> 50.50.50.52
> kaf3.kafka.mydns -> 50.50.50.53
>
> Those are the name in the DNS.
>
> In my /etc/hostname and when I was doing the commande 'hostname' the output
> was kaf1 (kaf2 and kaf3 for the other brokers)
> In my /etc/hosts, i had for every broker the following :
> 127.0.0.1 localhost
> 50.50.50.51 kaf1 kaf1.kafka.mydns
> 50.50.50.52 kaf2 kaf2.kafka.mydns
> 50.50.50.53 kaf3 kaf3.kafka.mydns
>
> In zookeeper, the command "get /brokers/ids/1" has returning
> '..."host":"kaf1"...'
> and I found out in the log that my producer and consumer has using kaf1
> (kaf2 and kaf3) to connect to the brokers but does aren't map in my DNS or
> in the hosts files so it has not able to connect...
>
> After that I change the hostname (by editing the /etc/hostname and using
> 'hostname <newHostname>') and then I restart everything to be sure and I
> even removed my data and my zknode
>
> *And the wierd behaviour is that after I restarted everything the "get
> /brokers/ids/1" kept returning '..."host":"kaf1"...' *
>
> To correct the situation, I changed my /etc/hosts on every brokers to the
> following :
> 127.0.0.1 localhost
> 50.50.50.51 kaf1.kafka.mydns
> 50.50.50.52 kaf2.kafka.mydns
> 50.50.50.53 kaf3.kafka.mydns
>
> (Removing the kaf1 (kaf2 and kaf3) and just keeping the fqdn)
>
> after restarting everything, it now works and the command "get
> /brokers/ids/1" now return '..."host":"kaf1.kafka.mydns"...'
>
> From what I understand, I don't thing that the broker should take his
> hostname from the /etc/hosts file, no?
>
> Maybe this is cause by my OS (I'm not an expert of Debian) but I don't
> think so... and I don't think that this is the behaviour that you guys want
> to have too...
>
> Can someone reproduce the bug? Is that behaviour known?
>
>
>
> François Langelier
> Étudiant en génie Logiciel - École de Technologie Supérieure
> <http://www.etsmtl.ca/>
> Capitaine Club Capra <http://capra.etsmtl.ca/>
> VP-Communication - CS Games <http://csgames.org> 2014
> Jeux de Génie <http://www.jdgets.com/> 2011 à 2014
> Argentier Fraternité du Piranha <http://fraternitedupiranha.com/>
> 2012-2014
> Comité Organisateur Olympiades ÉTS 2012
> Compétition Québécoise d'Ingénierie 2012 - Compétition Senior
>
>
> On 11 June 2014 11:20, François Langelier <f....@gmail.com> wrote:
>
> > Thank Joel, I try to put the trace but I saw nothing... maybe I did it
> > wrong...
> >
> > anyway, I tried another way... I started the console consumer and
> > producer on a new topic to my remote brokers...
> >
> > The topic was create successfully but when i produce a message, nothing
> > happen...
> >
> > - The message is not consume
> > - I saw nothing on the brokers logs (for every broker)
> > - the .log file of the topic in my log.dirs is empty on every brokers
> > - I don't even have a logs file in my ./logs of my console producer
> > and consumer...
> >
> > Anyone have any idea???
> >
> > Thank!
> >
> >
> >
> > François Langelier
> > Étudiant en génie Logiciel - École de Technologie Supérieure
> > <http://www.etsmtl.ca/>
> > Capitaine Club Capra <http://capra.etsmtl.ca/>
> > VP-Communication - CS Games <http://csgames.org> 2014
> > Jeux de Génie <http://www.jdgets.com/> 2011 à 2014
> > Argentier Fraternité du Piranha <http://fraternitedupiranha.com/>
> > 2012-2014
> >
> > Comité Organisateur Olympiades ÉTS 2012
> > Compétition Québécoise d'Ingénierie 2012 - Compétition Senior
> >
> >
> > On 10 June 2014 17:32, Joel Koshy <jj...@gmail.com> wrote:
> >
> >> The broker logs that whenever it closes a connection to a client
> >> (e.g., if there was an error or the client decides to close its
> >> connection after talking to the broker).
> >>
> >> If you enable TRACE level on kafka.request.logger you can see
> >> precisely what requests are coming in.
> >>
> >> Joel
> >>
> >> On Tue, Jun 10, 2014 at 03:45:23PM -0400, François Langelier wrote:
> >> > Hi all!
> >> >
> >> > I have 3 brokers and I keep getting this message:
> >> > [kafka-processor-9092-0] INFO kafka.network.Processor - Closing
> socket
> >> > connection to /172.23.44.4.
> >> > or
> >> > [kafka-processor-9092-1] INFO kafka.network.Processor - Closing
> socket
> >> > connection to /172.23.44.4.
> >> >
> >> > Do anyone know what that means???
> >> >
> >> > (By the way, the IP isn't something in my network...)
> >> >
> >> > I'm using kafka 0.8.1.1 with scala 2.9.2
> >> >
> >> > thank for your help!
> >> >
> >> > Here is my log:
> >> >
> >> > [2014-06-10 18:43:58,332] 612950 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
> >> > > [TopicChangeListener on Controller 1]: New topics:
> >> > > [Set(REG_USER_TRACKING_LOG)], deleted topics: [Set()], new partition
> >> > > replica assignment [Map([REG_USER_TRACKING_LOG,0] -> List(1, 3, 2))]
> >> > > [2014-06-10 18:43:58,333] 612951 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.KafkaController - [Controller 1]: New topic
> >> > > creation callback for [REG_USER_TRACKING_LOG,0]
> >> > > [2014-06-10 18:43:58,336] 612954 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.KafkaController - [Controller 1]: New
> >> partition
> >> > > creation callback for [REG_USER_TRACKING_LOG,0]
> >> > > [2014-06-10 18:43:58,337] 612955 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.PartitionStateMachine - [Partition state
> >> machine on
> >> > > Controller 1]: Invoking state change to NewPartition for partitions
> >> > > [REG_USER_TRACKING_LOG,0]
> >> > > [2014-06-10 18:43:58,347] 612965 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine
> >> on
> >> > > controller 1]: Invoking state change to NewReplica for replicas
> >> > >
> >>
> [Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=1],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=3],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=2]
> >> > > [2014-06-10 18:43:58,352] 612970 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.PartitionStateMachine - [Partition state
> >> machine on
> >> > > Controller 1]: Invoking state change to OnlinePartition for
> partitions
> >> > > [REG_USER_TRACKING_LOG,0]
> >> > > [2014-06-10 18:43:58,470] 613088 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine
> >> on
> >> > > controller 1]: Invoking state change to OnlineReplica for replicas
> >> > >
> >>
> [Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=1],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=3],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=2]
> >> > > [2014-06-10 18:43:58,478] 613096 [kafka-request-handler-1] INFO
> >> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
> >> broker 1]
> >> > > Removed fetcher for partitions [REG_USER_TRACKING_LOG,0]
> >> > > [2014-06-10 18:43:58,533] 613151 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:43:58,538] 613156 [kafka-request-handler-1] INFO
> >> > > kafka.log.Log - Completed load of log REG_USER_TRACKING_LOG-0 with
> >> log
> >> > > end offset 0
> >> > > [2014-06-10 18:43:58,546] 613164 [kafka-request-handler-1] INFO
> >> > > kafka.log.LogManager - Created log for partition
> >> > > [REG_USER_TRACKING_LOG,0] in /var/spool/kafka with properties
> >> > > {segment.index.bytes -> 10485760, file.delete.delay.ms -> 60000,
> >> > > segment.bytes -> 536870912, flush.ms -> 9223372036854775807,
> >> > > delete.retention.ms -> 86400000, index.interval.bytes -> 4096,
> >> > > retention.bytes -> -1, cleanup.policy -> delete, segment.ms ->
> >> 604800000,
> >> > > max.message.bytes -> 1000012, flush.messages -> 9223372036854775807,
> >> > > min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
> >> > > [2014-06-10 18:43:58,547] 613165 [kafka-request-handler-1] WARN
> >> > > kafka.cluster.Partition - Partition [REG_USER_TRACKING_LOG,0] on
> >> broker
> >> > > 1: No checkpointed highwatermark is found for partition
> >> > > [REG_USER_TRACKING_LOG,0]
> >> > > [2014-06-10 18:43:59,372] 613990 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:43:59,577] 614195 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:43:59,782] 614400 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:43:59,988] 614606 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:00,622] 615240 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:01,033] 615651 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:01,115] 615733 [kafka-request-handler-3] INFO
> >> > > kafka.admin.AdminUtils$ - Topic creation
> >> > > {"version":1,"partitions":{"0":[3,1,2]}}
> >> > > [2014-06-10 18:44:01,140] 615758 [kafka-request-handler-3] INFO
> >> > > kafka.server.KafkaApis - [KafkaApi-1] Auto creation of topic
> >> > > RULE_RECRIMINATION with 1 partitions and replication factor 3 is
> >> successful!
> >> > > [2014-06-10 18:44:01,141] 615759 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:01,150] 615768 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
> >> > > [TopicChangeListener on Controller 1]: New topics:
> >> > > [Set(RULE_RECRIMINATION)], deleted topics: [Set()], new partition
> >> replica
> >> > > assignment [Map([RULE_RECRIMINATION,0] -> List(3, 1, 2))]
> >> > > [2014-06-10 18:44:01,150] 615768 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.KafkaController - [Controller 1]: New topic
> >> > > creation callback for [RULE_RECRIMINATION,0]
> >> > > [2014-06-10 18:44:01,151] 615769 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.KafkaController - [Controller 1]: New
> >> partition
> >> > > creation callback for [RULE_RECRIMINATION,0]
> >> > > [2014-06-10 18:44:01,151] 615769 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.PartitionStateMachine - [Partition state
> >> machine on
> >> > > Controller 1]: Invoking state change to NewPartition for partitions
> >> > > [RULE_RECRIMINATION,0]
> >> > > [2014-06-10 18:44:01,157] 615775 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine
> >> on
> >> > > controller 1]: Invoking state change to NewReplica for replicas
> >> > >
> >>
> [Topic=RULE_RECRIMINATION,Partition=0,Replica=3],[Topic=RULE_RECRIMINATION,Partition=0,Replica=1],[Topic=RULE_RECRIMINATION,Partition=0,Replica=2]
> >> > > [2014-06-10 18:44:01,159] 615777 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.PartitionStateMachine - [Partition state
> >> machine on
> >> > > Controller 1]: Invoking state change to OnlinePartition for
> partitions
> >> > > [RULE_RECRIMINATION,0]
> >> > > [2014-06-10 18:44:01,223] 615841 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine
> >> on
> >> > > controller 1]: Invoking state change to OnlineReplica for replicas
> >> > >
> >>
> [Topic=RULE_RECRIMINATION,Partition=0,Replica=3],[Topic=RULE_RECRIMINATION,Partition=0,Replica=1],[Topic=RULE_RECRIMINATION,Partition=0,Replica=2]
> >> > > [2014-06-10 18:44:01,231] 615849 [kafka-request-handler-6] INFO
> >> > > kafka.log.Log - Completed load of log RULE_RECRIMINATION-0 with
> log
> >> end
> >> > > offset 0
> >> > > [2014-06-10 18:44:01,232] 615850 [kafka-request-handler-6] INFO
> >> > > kafka.log.LogManager - Created log for partition
> >> [RULE_RECRIMINATION,0]
> >> > > in /var/spool/kafka with properties {segment.index.bytes ->
> 10485760,
> >> > > file.delete.delay.ms -> 60000, segment.bytes -> 536870912, flush.ms
> >> ->
> >> > > 9223372036854775807, delete.retention.ms -> 86400000,
> >> > > index.interval.bytes -> 4096, retention.bytes -> -1, cleanup.policy
> ->
> >> > > delete, segment.ms -> 604800000, max.message.bytes -> 1000012,
> >> > > flush.messages -> 9223372036854775807, min.cleanable.dirty.ratio ->
> >> 0.5,
> >> > > retention.ms -> 604800000}.
> >> > > [2014-06-10 18:44:01,233] 615851 [kafka-request-handler-6] WARN
> >> > > kafka.cluster.Partition - Partition [RULE_RECRIMINATION,0] on
> >> broker 1:
> >> > > No checkpointed highwatermark is found for partition
> >> [RULE_RECRIMINATION,0]
> >> > > [2014-06-10 18:44:01,235] 615853 [kafka-request-handler-6] INFO
> >> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
> >> broker 1]
> >> > > Removed fetcher for partitions [RULE_RECRIMINATION,0]
> >> > > [2014-06-10 18:44:01,238] 615856 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:01,239] 615857 [kafka-request-handler-6] INFO
> >> > > kafka.log.Log - Truncating log RULE_RECRIMINATION-0 to offset 0.
> >> > > [2014-06-10 18:44:01,265] 615883 [ReplicaFetcherThread-0-3] INFO
> >> > > kafka.server.ReplicaFetcherThread - [ReplicaFetcherThread-0-3],
> >> Starting
> >> > > [2014-06-10 18:44:01,270] 615888 [kafka-request-handler-6] INFO
> >> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
> >> broker 1]
> >> > > Added fetcher for partitions ArrayBuffer([[RULE_RECRIMINATION,0],
> >> > > initOffset 0 to broker id:3,host:kaf3,port:9092] )
> >> > > [2014-06-10 18:44:01,344] 615962 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:01,354] 615972 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:01,549] 616167 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:01,649] 616267 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:01,986] 616604 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:02,470] 617088 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:02,610] 617228 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:02,818] 617436 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:03,025] 617643 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:03,194] 617812 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:03,233] 617851 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:03,649] 618267 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:04,015] 618633 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:04,064] 618682 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:04,272] 618890 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:04,480] 619098 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:04,526] 619144 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:04,634] 619252 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:04,731] 619349 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:04,936] 619554 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:05,141] 619759 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:05,308] 619926 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:05,346] 619964 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:05,456] 620074 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:05,516] 620134 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:05,723] 620341 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:06,687] 621305 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:07,175] 621793 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:07,381] 621999 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:07,397] 622015 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:07,796] 622414 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:08,217] 622835 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:08,328] 622946 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:09,041] 623659 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:09,152] 623770 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:10,074] 624692 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:10,176] 624794 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:10,380] 624998 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:10,488] 625106 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:10,585] 625203 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:10,694] 625312 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:10,790] 625408 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:11,200] 625818 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:11,613] 626231 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:11,731] 626349 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:58,282] 672900 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
> >> > > [TopicChangeListener on Controller 1]: New topics:
> >> > > [Set(KAFKA_LOGGING_MESSAGE)], deleted topics: [Set()], new partition
> >> > > replica assignment [Map([KAFKA_LOGGING_MESSAGE,0] -> List(3, 1, 2))]
> >> > > [2014-06-10 18:44:58,282] 672900 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.KafkaController - [Controller 1]: New topic
> >> > > creation callback for [KAFKA_LOGGING_MESSAGE,0]
> >> > > [2014-06-10 18:44:58,283] 672901 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.KafkaController - [Controller 1]: New
> >> partition
> >> > > creation callback for [KAFKA_LOGGING_MESSAGE,0]
> >> > > [2014-06-10 18:44:58,283] 672901 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.PartitionStateMachine - [Partition state
> >> machine on
> >> > > Controller 1]: Invoking state change to NewPartition for partitions
> >> > > [KAFKA_LOGGING_MESSAGE,0]
> >> > > [2014-06-10 18:44:58,287] 672905 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:58,287] 672905 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine
> >> on
> >> > > controller 1]: Invoking state change to NewReplica for replicas
> >> > >
> >>
> [Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=3],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=1],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=2]
> >> > > [2014-06-10 18:44:58,292] 672910 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.PartitionStateMachine - [Partition state
> >> machine on
> >> > > Controller 1]: Invoking state change to OnlinePartition for
> partitions
> >> > > [KAFKA_LOGGING_MESSAGE,0]
> >> > > [2014-06-10 18:44:58,351] 672969 [
> >> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> >> > > two.backup.zk.three.qa:2181,
> >> three.backup.zk.three.qa:2181/kafka0.8.1.1]
> >> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine
> >> on
> >> > > controller 1]: Invoking state change to OnlineReplica for replicas
> >> > >
> >>
> [Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=3],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=1],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=2]
> >> > > [2014-06-10 18:44:58,362] 672980 [kafka-request-handler-1] INFO
> >> > > kafka.log.Log - Completed load of log KAFKA_LOGGING_MESSAGE-0 with
> >> log
> >> > > end offset 0
> >> > > [2014-06-10 18:44:58,367] 672985 [kafka-request-handler-1] INFO
> >> > > kafka.log.LogManager - Created log for partition
> >> > > [KAFKA_LOGGING_MESSAGE,0] in /var/spool/kafka with properties
> >> > > {segment.index.bytes -> 10485760, file.delete.delay.ms -> 60000,
> >> > > segment.bytes -> 536870912, flush.ms -> 9223372036854775807,
> >> > > delete.retention.ms -> 86400000, index.interval.bytes -> 4096,
> >> > > retention.bytes -> -1, cleanup.policy -> delete, segment.ms ->
> >> 604800000,
> >> > > max.message.bytes -> 1000012, flush.messages -> 9223372036854775807,
> >> > > min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
> >> > > [2014-06-10 18:44:58,374] 672992 [kafka-request-handler-1] WARN
> >> > > kafka.cluster.Partition - Partition [KAFKA_LOGGING_MESSAGE,0] on
> >> broker
> >> > > 1: No checkpointed highwatermark is found for partition
> >> > > [KAFKA_LOGGING_MESSAGE,0]
> >> > > [2014-06-10 18:44:58,375] 672993 [kafka-request-handler-1] INFO
> >> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
> >> broker 1]
> >> > > Removed fetcher for partitions [KAFKA_LOGGING_MESSAGE,0]
> >> > > [2014-06-10 18:44:58,376] 672994 [kafka-request-handler-1] INFO
> >> > > kafka.log.Log - Truncating log KAFKA_LOGGING_MESSAGE-0 to offset
> 0.
> >> > > [2014-06-10 18:44:58,377] 672995 [kafka-request-handler-1] INFO
> >> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
> >> broker 1]
> >> > > Added fetcher for partitions ArrayBuffer([[KAFKA_LOGGING_MESSAGE,0],
> >> > > initOffset 0 to broker id:3,host:kaf3,port:9092] )
> >> > > [2014-06-10 18:44:58,706] 673324 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:58,911] 673529 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:59,116] 673734 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:59,321] 673939 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:59,526] 674144 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:44:59,938] 674556 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:00,143] 674761 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:00,554] 675172 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:01,171] 675789 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:01,581] 676199 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:01,934] 676552 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:02,345] 676963 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:02,550] 677168 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:02,756] 677374 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:03,434] 678052 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:03,988] 678606 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:04,464] 679082 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:04,605] 679223 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:04,670] 679288 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:05,226] 679844 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:05,491] 680109 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:06,048] 680666 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:06,254] 680872 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:06,459] 681077 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:06,518] 681136 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:07,485] 682103 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:07,690] 682308 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:07,955] 682573 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:08,101] 682719 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:08,570] 683188 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:08,722] 683340 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:09,139] 683757 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:09,345] 683963 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:09,550] 684168 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:10,989] 685607 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:11,401] 686019 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:45:11,605] 686223 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:04,680] 1099298 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:05,090] 1099708 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:05,704] 1100322 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:05,909] 1100527 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:06,935] 1101553 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:07,455] 1102073 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:07,998] 1102616 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:08,163] 1102781 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:08,411] 1103029 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:08,823] 1103441 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:09,030] 1103648 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:09,089] 1103707 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:09,236] 1103854 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:09,391] 1104009 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:09,442] 1104060 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:09,595] 1104213 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:09,903] 1104521 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:10,061] 1104679 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:10,266] 1104884 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:10,311] 1104929 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:10,416] 1105034 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:10,620] 1105238 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:10,884] 1105502 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:11,296] 1105914 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:11,741] 1106359 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:11,945] 1106563 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:12,051] 1106669 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:12,324] 1106942 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:12,459] 1107077 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:12,529] 1107147 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:12,736] 1107354 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:12,941] 1107559 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:13,147] 1107765 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:13,375] 1107993 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:13,481] 1108099 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:13,559] 1108177 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:13,579] 1108197 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:13,686] 1108304 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:13,764] 1108382 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:13,782] 1108400 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:14,176] 1108794 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:14,191] 1108809 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:14,793] 1109411 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:15,204] 1109822 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:15,211] 1109829 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:15,823] 1110441 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:16,029] 1110647 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:16,645] 1111263 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:16,850] 1111468 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:17,053] 1111671 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:54,009] 1148627 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:55,440] 1150058 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:56,054] 1150672 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:56,258] 1150876 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:56,668] 1151286 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:57,445] 1152063 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:57,853] 1152471 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:58,261] 1152879 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:58,466] 1153084 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:58,670] 1153288 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:58,711] 1153329 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:59,283] 1153901 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:52:59,488] 1154106 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:00,100] 1154718 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:01,165] 1155783 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:01,325] 1155943 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:01,369] 1155987 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:01,778] 1156396 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:02,187] 1156805 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:02,550] 1157168 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:02,594] 1157212 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:02,958] 1157576 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:03,367] 1157985 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:03,616] 1158234 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:03,979] 1158597 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:04,388] 1159006 [kafka-processor-9092-0] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> > > [2014-06-10 18:53:04,796] 1159414 [kafka-processor-9092-1] INFO
> >> > > kafka.network.Processor - Closing socket connection to /
> 172.23.44.4
> >> .
> >> >
> >> >
> >> >
> >> >
> >> > François Langelier
> >> > Étudiant en génie Logiciel - École de Technologie Supérieure
> >> > <http://www.etsmtl.ca/>
> >> > Capitaine Club Capra <http://capra.etsmtl.ca/>
> >> > VP-Communication - CS Games <http://csgames.org> 2014
> >> > Jeux de Génie <http://www.jdgets.com/> 2011 à 2014
> >> > Argentier Fraternité du Piranha <http://fraternitedupiranha.com/>
> >> 2012-2014
> >> > Comité Organisateur Olympiades ÉTS 2012
> >> > Compétition Québécoise d'Ingénierie 2012 - Compétition Senior
> >>
> >>
> >
>
Re: spam of [kafka-processor-9092-0] INFO kafka.network.Processor -
Closing socket connection to /172.23.44.4.
Posted by François Langelier <f....@gmail.com>.
FYI, I found out what was wrong and I think it's a wierd behaviour that you
guys may want to fix...
First of all, my setup is the following
I have 3 brokers named :
kaf1.kafka.mydns -> 50.50.50.51
kaf2.kafka.mydns -> 50.50.50.52
kaf3.kafka.mydns -> 50.50.50.53
Those are the name in the DNS.
In my /etc/hostname and when I was doing the commande 'hostname' the output
was kaf1 (kaf2 and kaf3 for the other brokers)
In my /etc/hosts, i had for every broker the following :
127.0.0.1 localhost
50.50.50.51 kaf1 kaf1.kafka.mydns
50.50.50.52 kaf2 kaf2.kafka.mydns
50.50.50.53 kaf3 kaf3.kafka.mydns
In zookeeper, the command "get /brokers/ids/1" has returning
'..."host":"kaf1"...'
and I found out in the log that my producer and consumer has using kaf1
(kaf2 and kaf3) to connect to the brokers but does aren't map in my DNS or
in the hosts files so it has not able to connect...
After that I change the hostname (by editing the /etc/hostname and using
'hostname <newHostname>') and then I restart everything to be sure and I
even removed my data and my zknode
*And the wierd behaviour is that after I restarted everything the "get
/brokers/ids/1" kept returning '..."host":"kaf1"...' *
To correct the situation, I changed my /etc/hosts on every brokers to the
following :
127.0.0.1 localhost
50.50.50.51 kaf1.kafka.mydns
50.50.50.52 kaf2.kafka.mydns
50.50.50.53 kaf3.kafka.mydns
(Removing the kaf1 (kaf2 and kaf3) and just keeping the fqdn)
after restarting everything, it now works and the command "get
/brokers/ids/1" now return '..."host":"kaf1.kafka.mydns"...'
>From what I understand, I don't thing that the broker should take his
hostname from the /etc/hosts file, no?
Maybe this is cause by my OS (I'm not an expert of Debian) but I don't
think so... and I don't think that this is the behaviour that you guys want
to have too...
Can someone reproduce the bug? Is that behaviour known?
François Langelier
Étudiant en génie Logiciel - École de Technologie Supérieure
<http://www.etsmtl.ca/>
Capitaine Club Capra <http://capra.etsmtl.ca/>
VP-Communication - CS Games <http://csgames.org> 2014
Jeux de Génie <http://www.jdgets.com/> 2011 à 2014
Argentier Fraternité du Piranha <http://fraternitedupiranha.com/> 2012-2014
Comité Organisateur Olympiades ÉTS 2012
Compétition Québécoise d'Ingénierie 2012 - Compétition Senior
On 11 June 2014 11:20, François Langelier <f....@gmail.com> wrote:
> Thank Joel, I try to put the trace but I saw nothing... maybe I did it
> wrong...
>
> anyway, I tried another way... I started the console consumer and
> producer on a new topic to my remote brokers...
>
> The topic was create successfully but when i produce a message, nothing
> happen...
>
> - The message is not consume
> - I saw nothing on the brokers logs (for every broker)
> - the .log file of the topic in my log.dirs is empty on every brokers
> - I don't even have a logs file in my ./logs of my console producer
> and consumer...
>
> Anyone have any idea???
>
> Thank!
>
>
>
> François Langelier
> Étudiant en génie Logiciel - École de Technologie Supérieure
> <http://www.etsmtl.ca/>
> Capitaine Club Capra <http://capra.etsmtl.ca/>
> VP-Communication - CS Games <http://csgames.org> 2014
> Jeux de Génie <http://www.jdgets.com/> 2011 à 2014
> Argentier Fraternité du Piranha <http://fraternitedupiranha.com/>
> 2012-2014
>
> Comité Organisateur Olympiades ÉTS 2012
> Compétition Québécoise d'Ingénierie 2012 - Compétition Senior
>
>
> On 10 June 2014 17:32, Joel Koshy <jj...@gmail.com> wrote:
>
>> The broker logs that whenever it closes a connection to a client
>> (e.g., if there was an error or the client decides to close its
>> connection after talking to the broker).
>>
>> If you enable TRACE level on kafka.request.logger you can see
>> precisely what requests are coming in.
>>
>> Joel
>>
>> On Tue, Jun 10, 2014 at 03:45:23PM -0400, François Langelier wrote:
>> > Hi all!
>> >
>> > I have 3 brokers and I keep getting this message:
>> > [kafka-processor-9092-0] INFO kafka.network.Processor - Closing socket
>> > connection to /172.23.44.4.
>> > or
>> > [kafka-processor-9092-1] INFO kafka.network.Processor - Closing socket
>> > connection to /172.23.44.4.
>> >
>> > Do anyone know what that means???
>> >
>> > (By the way, the IP isn't something in my network...)
>> >
>> > I'm using kafka 0.8.1.1 with scala 2.9.2
>> >
>> > thank for your help!
>> >
>> > Here is my log:
>> >
>> > [2014-06-10 18:43:58,332] 612950 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
>> > > [TopicChangeListener on Controller 1]: New topics:
>> > > [Set(REG_USER_TRACKING_LOG)], deleted topics: [Set()], new partition
>> > > replica assignment [Map([REG_USER_TRACKING_LOG,0] -> List(1, 3, 2))]
>> > > [2014-06-10 18:43:58,333] 612951 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.KafkaController - [Controller 1]: New topic
>> > > creation callback for [REG_USER_TRACKING_LOG,0]
>> > > [2014-06-10 18:43:58,336] 612954 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.KafkaController - [Controller 1]: New
>> partition
>> > > creation callback for [REG_USER_TRACKING_LOG,0]
>> > > [2014-06-10 18:43:58,337] 612955 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.PartitionStateMachine - [Partition state
>> machine on
>> > > Controller 1]: Invoking state change to NewPartition for partitions
>> > > [REG_USER_TRACKING_LOG,0]
>> > > [2014-06-10 18:43:58,347] 612965 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine
>> on
>> > > controller 1]: Invoking state change to NewReplica for replicas
>> > >
>> [Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=1],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=3],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=2]
>> > > [2014-06-10 18:43:58,352] 612970 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.PartitionStateMachine - [Partition state
>> machine on
>> > > Controller 1]: Invoking state change to OnlinePartition for partitions
>> > > [REG_USER_TRACKING_LOG,0]
>> > > [2014-06-10 18:43:58,470] 613088 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine
>> on
>> > > controller 1]: Invoking state change to OnlineReplica for replicas
>> > >
>> [Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=1],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=3],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=2]
>> > > [2014-06-10 18:43:58,478] 613096 [kafka-request-handler-1] INFO
>> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
>> broker 1]
>> > > Removed fetcher for partitions [REG_USER_TRACKING_LOG,0]
>> > > [2014-06-10 18:43:58,533] 613151 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:43:58,538] 613156 [kafka-request-handler-1] INFO
>> > > kafka.log.Log - Completed load of log REG_USER_TRACKING_LOG-0 with
>> log
>> > > end offset 0
>> > > [2014-06-10 18:43:58,546] 613164 [kafka-request-handler-1] INFO
>> > > kafka.log.LogManager - Created log for partition
>> > > [REG_USER_TRACKING_LOG,0] in /var/spool/kafka with properties
>> > > {segment.index.bytes -> 10485760, file.delete.delay.ms -> 60000,
>> > > segment.bytes -> 536870912, flush.ms -> 9223372036854775807,
>> > > delete.retention.ms -> 86400000, index.interval.bytes -> 4096,
>> > > retention.bytes -> -1, cleanup.policy -> delete, segment.ms ->
>> 604800000,
>> > > max.message.bytes -> 1000012, flush.messages -> 9223372036854775807,
>> > > min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
>> > > [2014-06-10 18:43:58,547] 613165 [kafka-request-handler-1] WARN
>> > > kafka.cluster.Partition - Partition [REG_USER_TRACKING_LOG,0] on
>> broker
>> > > 1: No checkpointed highwatermark is found for partition
>> > > [REG_USER_TRACKING_LOG,0]
>> > > [2014-06-10 18:43:59,372] 613990 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:43:59,577] 614195 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:43:59,782] 614400 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:43:59,988] 614606 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:00,622] 615240 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:01,033] 615651 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:01,115] 615733 [kafka-request-handler-3] INFO
>> > > kafka.admin.AdminUtils$ - Topic creation
>> > > {"version":1,"partitions":{"0":[3,1,2]}}
>> > > [2014-06-10 18:44:01,140] 615758 [kafka-request-handler-3] INFO
>> > > kafka.server.KafkaApis - [KafkaApi-1] Auto creation of topic
>> > > RULE_RECRIMINATION with 1 partitions and replication factor 3 is
>> successful!
>> > > [2014-06-10 18:44:01,141] 615759 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:01,150] 615768 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
>> > > [TopicChangeListener on Controller 1]: New topics:
>> > > [Set(RULE_RECRIMINATION)], deleted topics: [Set()], new partition
>> replica
>> > > assignment [Map([RULE_RECRIMINATION,0] -> List(3, 1, 2))]
>> > > [2014-06-10 18:44:01,150] 615768 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.KafkaController - [Controller 1]: New topic
>> > > creation callback for [RULE_RECRIMINATION,0]
>> > > [2014-06-10 18:44:01,151] 615769 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.KafkaController - [Controller 1]: New
>> partition
>> > > creation callback for [RULE_RECRIMINATION,0]
>> > > [2014-06-10 18:44:01,151] 615769 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.PartitionStateMachine - [Partition state
>> machine on
>> > > Controller 1]: Invoking state change to NewPartition for partitions
>> > > [RULE_RECRIMINATION,0]
>> > > [2014-06-10 18:44:01,157] 615775 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine
>> on
>> > > controller 1]: Invoking state change to NewReplica for replicas
>> > >
>> [Topic=RULE_RECRIMINATION,Partition=0,Replica=3],[Topic=RULE_RECRIMINATION,Partition=0,Replica=1],[Topic=RULE_RECRIMINATION,Partition=0,Replica=2]
>> > > [2014-06-10 18:44:01,159] 615777 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.PartitionStateMachine - [Partition state
>> machine on
>> > > Controller 1]: Invoking state change to OnlinePartition for partitions
>> > > [RULE_RECRIMINATION,0]
>> > > [2014-06-10 18:44:01,223] 615841 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine
>> on
>> > > controller 1]: Invoking state change to OnlineReplica for replicas
>> > >
>> [Topic=RULE_RECRIMINATION,Partition=0,Replica=3],[Topic=RULE_RECRIMINATION,Partition=0,Replica=1],[Topic=RULE_RECRIMINATION,Partition=0,Replica=2]
>> > > [2014-06-10 18:44:01,231] 615849 [kafka-request-handler-6] INFO
>> > > kafka.log.Log - Completed load of log RULE_RECRIMINATION-0 with log
>> end
>> > > offset 0
>> > > [2014-06-10 18:44:01,232] 615850 [kafka-request-handler-6] INFO
>> > > kafka.log.LogManager - Created log for partition
>> [RULE_RECRIMINATION,0]
>> > > in /var/spool/kafka with properties {segment.index.bytes -> 10485760,
>> > > file.delete.delay.ms -> 60000, segment.bytes -> 536870912, flush.ms
>> ->
>> > > 9223372036854775807, delete.retention.ms -> 86400000,
>> > > index.interval.bytes -> 4096, retention.bytes -> -1, cleanup.policy ->
>> > > delete, segment.ms -> 604800000, max.message.bytes -> 1000012,
>> > > flush.messages -> 9223372036854775807, min.cleanable.dirty.ratio ->
>> 0.5,
>> > > retention.ms -> 604800000}.
>> > > [2014-06-10 18:44:01,233] 615851 [kafka-request-handler-6] WARN
>> > > kafka.cluster.Partition - Partition [RULE_RECRIMINATION,0] on
>> broker 1:
>> > > No checkpointed highwatermark is found for partition
>> [RULE_RECRIMINATION,0]
>> > > [2014-06-10 18:44:01,235] 615853 [kafka-request-handler-6] INFO
>> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
>> broker 1]
>> > > Removed fetcher for partitions [RULE_RECRIMINATION,0]
>> > > [2014-06-10 18:44:01,238] 615856 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:01,239] 615857 [kafka-request-handler-6] INFO
>> > > kafka.log.Log - Truncating log RULE_RECRIMINATION-0 to offset 0.
>> > > [2014-06-10 18:44:01,265] 615883 [ReplicaFetcherThread-0-3] INFO
>> > > kafka.server.ReplicaFetcherThread - [ReplicaFetcherThread-0-3],
>> Starting
>> > > [2014-06-10 18:44:01,270] 615888 [kafka-request-handler-6] INFO
>> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
>> broker 1]
>> > > Added fetcher for partitions ArrayBuffer([[RULE_RECRIMINATION,0],
>> > > initOffset 0 to broker id:3,host:kaf3,port:9092] )
>> > > [2014-06-10 18:44:01,344] 615962 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:01,354] 615972 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:01,549] 616167 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:01,649] 616267 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:01,986] 616604 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:02,470] 617088 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:02,610] 617228 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:02,818] 617436 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:03,025] 617643 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:03,194] 617812 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:03,233] 617851 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:03,649] 618267 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:04,015] 618633 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:04,064] 618682 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:04,272] 618890 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:04,480] 619098 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:04,526] 619144 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:04,634] 619252 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:04,731] 619349 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:04,936] 619554 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:05,141] 619759 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:05,308] 619926 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:05,346] 619964 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:05,456] 620074 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:05,516] 620134 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:05,723] 620341 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:06,687] 621305 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:07,175] 621793 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:07,381] 621999 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:07,397] 622015 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:07,796] 622414 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:08,217] 622835 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:08,328] 622946 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:09,041] 623659 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:09,152] 623770 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:10,074] 624692 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:10,176] 624794 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:10,380] 624998 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:10,488] 625106 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:10,585] 625203 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:10,694] 625312 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:10,790] 625408 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:11,200] 625818 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:11,613] 626231 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:11,731] 626349 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:58,282] 672900 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
>> > > [TopicChangeListener on Controller 1]: New topics:
>> > > [Set(KAFKA_LOGGING_MESSAGE)], deleted topics: [Set()], new partition
>> > > replica assignment [Map([KAFKA_LOGGING_MESSAGE,0] -> List(3, 1, 2))]
>> > > [2014-06-10 18:44:58,282] 672900 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.KafkaController - [Controller 1]: New topic
>> > > creation callback for [KAFKA_LOGGING_MESSAGE,0]
>> > > [2014-06-10 18:44:58,283] 672901 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.KafkaController - [Controller 1]: New
>> partition
>> > > creation callback for [KAFKA_LOGGING_MESSAGE,0]
>> > > [2014-06-10 18:44:58,283] 672901 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.PartitionStateMachine - [Partition state
>> machine on
>> > > Controller 1]: Invoking state change to NewPartition for partitions
>> > > [KAFKA_LOGGING_MESSAGE,0]
>> > > [2014-06-10 18:44:58,287] 672905 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:58,287] 672905 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine
>> on
>> > > controller 1]: Invoking state change to NewReplica for replicas
>> > >
>> [Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=3],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=1],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=2]
>> > > [2014-06-10 18:44:58,292] 672910 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.PartitionStateMachine - [Partition state
>> machine on
>> > > Controller 1]: Invoking state change to OnlinePartition for partitions
>> > > [KAFKA_LOGGING_MESSAGE,0]
>> > > [2014-06-10 18:44:58,351] 672969 [
>> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
>> > > two.backup.zk.three.qa:2181,
>> three.backup.zk.three.qa:2181/kafka0.8.1.1]
>> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine
>> on
>> > > controller 1]: Invoking state change to OnlineReplica for replicas
>> > >
>> [Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=3],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=1],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=2]
>> > > [2014-06-10 18:44:58,362] 672980 [kafka-request-handler-1] INFO
>> > > kafka.log.Log - Completed load of log KAFKA_LOGGING_MESSAGE-0 with
>> log
>> > > end offset 0
>> > > [2014-06-10 18:44:58,367] 672985 [kafka-request-handler-1] INFO
>> > > kafka.log.LogManager - Created log for partition
>> > > [KAFKA_LOGGING_MESSAGE,0] in /var/spool/kafka with properties
>> > > {segment.index.bytes -> 10485760, file.delete.delay.ms -> 60000,
>> > > segment.bytes -> 536870912, flush.ms -> 9223372036854775807,
>> > > delete.retention.ms -> 86400000, index.interval.bytes -> 4096,
>> > > retention.bytes -> -1, cleanup.policy -> delete, segment.ms ->
>> 604800000,
>> > > max.message.bytes -> 1000012, flush.messages -> 9223372036854775807,
>> > > min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
>> > > [2014-06-10 18:44:58,374] 672992 [kafka-request-handler-1] WARN
>> > > kafka.cluster.Partition - Partition [KAFKA_LOGGING_MESSAGE,0] on
>> broker
>> > > 1: No checkpointed highwatermark is found for partition
>> > > [KAFKA_LOGGING_MESSAGE,0]
>> > > [2014-06-10 18:44:58,375] 672993 [kafka-request-handler-1] INFO
>> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
>> broker 1]
>> > > Removed fetcher for partitions [KAFKA_LOGGING_MESSAGE,0]
>> > > [2014-06-10 18:44:58,376] 672994 [kafka-request-handler-1] INFO
>> > > kafka.log.Log - Truncating log KAFKA_LOGGING_MESSAGE-0 to offset 0.
>> > > [2014-06-10 18:44:58,377] 672995 [kafka-request-handler-1] INFO
>> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
>> broker 1]
>> > > Added fetcher for partitions ArrayBuffer([[KAFKA_LOGGING_MESSAGE,0],
>> > > initOffset 0 to broker id:3,host:kaf3,port:9092] )
>> > > [2014-06-10 18:44:58,706] 673324 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:58,911] 673529 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:59,116] 673734 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:59,321] 673939 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:59,526] 674144 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:44:59,938] 674556 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:00,143] 674761 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:00,554] 675172 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:01,171] 675789 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:01,581] 676199 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:01,934] 676552 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:02,345] 676963 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:02,550] 677168 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:02,756] 677374 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:03,434] 678052 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:03,988] 678606 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:04,464] 679082 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:04,605] 679223 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:04,670] 679288 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:05,226] 679844 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:05,491] 680109 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:06,048] 680666 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:06,254] 680872 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:06,459] 681077 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:06,518] 681136 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:07,485] 682103 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:07,690] 682308 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:07,955] 682573 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:08,101] 682719 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:08,570] 683188 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:08,722] 683340 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:09,139] 683757 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:09,345] 683963 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:09,550] 684168 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:10,989] 685607 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:11,401] 686019 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:45:11,605] 686223 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:04,680] 1099298 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:05,090] 1099708 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:05,704] 1100322 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:05,909] 1100527 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:06,935] 1101553 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:07,455] 1102073 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:07,998] 1102616 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:08,163] 1102781 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:08,411] 1103029 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:08,823] 1103441 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:09,030] 1103648 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:09,089] 1103707 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:09,236] 1103854 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:09,391] 1104009 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:09,442] 1104060 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:09,595] 1104213 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:09,903] 1104521 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:10,061] 1104679 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:10,266] 1104884 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:10,311] 1104929 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:10,416] 1105034 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:10,620] 1105238 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:10,884] 1105502 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:11,296] 1105914 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:11,741] 1106359 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:11,945] 1106563 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:12,051] 1106669 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:12,324] 1106942 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:12,459] 1107077 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:12,529] 1107147 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:12,736] 1107354 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:12,941] 1107559 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:13,147] 1107765 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:13,375] 1107993 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:13,481] 1108099 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:13,559] 1108177 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:13,579] 1108197 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:13,686] 1108304 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:13,764] 1108382 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:13,782] 1108400 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:14,176] 1108794 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:14,191] 1108809 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:14,793] 1109411 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:15,204] 1109822 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:15,211] 1109829 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:15,823] 1110441 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:16,029] 1110647 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:16,645] 1111263 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:16,850] 1111468 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:17,053] 1111671 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:54,009] 1148627 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:55,440] 1150058 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:56,054] 1150672 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:56,258] 1150876 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:56,668] 1151286 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:57,445] 1152063 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:57,853] 1152471 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:58,261] 1152879 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:58,466] 1153084 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:58,670] 1153288 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:58,711] 1153329 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:59,283] 1153901 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:52:59,488] 1154106 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:00,100] 1154718 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:01,165] 1155783 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:01,325] 1155943 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:01,369] 1155987 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:01,778] 1156396 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:02,187] 1156805 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:02,550] 1157168 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:02,594] 1157212 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:02,958] 1157576 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:03,367] 1157985 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:03,616] 1158234 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:03,979] 1158597 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:04,388] 1159006 [kafka-processor-9092-0] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> > > [2014-06-10 18:53:04,796] 1159414 [kafka-processor-9092-1] INFO
>> > > kafka.network.Processor - Closing socket connection to /172.23.44.4
>> .
>> >
>> >
>> >
>> >
>> > François Langelier
>> > Étudiant en génie Logiciel - École de Technologie Supérieure
>> > <http://www.etsmtl.ca/>
>> > Capitaine Club Capra <http://capra.etsmtl.ca/>
>> > VP-Communication - CS Games <http://csgames.org> 2014
>> > Jeux de Génie <http://www.jdgets.com/> 2011 à 2014
>> > Argentier Fraternité du Piranha <http://fraternitedupiranha.com/>
>> 2012-2014
>> > Comité Organisateur Olympiades ÉTS 2012
>> > Compétition Québécoise d'Ingénierie 2012 - Compétition Senior
>>
>>
>
Re: spam of [kafka-processor-9092-0] INFO kafka.network.Processor -
Closing socket connection to /172.23.44.4.
Posted by François Langelier <f....@gmail.com>.
Thank Joel, I try to put the trace but I saw nothing... maybe I did it
wrong...
anyway, I tried another way... I started the console consumer and producer
on a new topic to my remote brokers...
The topic was create successfully but when i produce a message, nothing
happen...
- The message is not consume
- I saw nothing on the brokers logs (for every broker)
- the .log file of the topic in my log.dirs is empty on every brokers
- I don't even have a logs file in my ./logs of my console producer and
consumer...
Anyone have any idea???
Thank!
François Langelier
Étudiant en génie Logiciel - École de Technologie Supérieure
<http://www.etsmtl.ca/>
Capitaine Club Capra <http://capra.etsmtl.ca/>
VP-Communication - CS Games <http://csgames.org> 2014
Jeux de Génie <http://www.jdgets.com/> 2011 à 2014
Argentier Fraternité du Piranha <http://fraternitedupiranha.com/> 2012-2014
Comité Organisateur Olympiades ÉTS 2012
Compétition Québécoise d'Ingénierie 2012 - Compétition Senior
On 10 June 2014 17:32, Joel Koshy <jj...@gmail.com> wrote:
> The broker logs that whenever it closes a connection to a client
> (e.g., if there was an error or the client decides to close its
> connection after talking to the broker).
>
> If you enable TRACE level on kafka.request.logger you can see
> precisely what requests are coming in.
>
> Joel
>
> On Tue, Jun 10, 2014 at 03:45:23PM -0400, François Langelier wrote:
> > Hi all!
> >
> > I have 3 brokers and I keep getting this message:
> > [kafka-processor-9092-0] INFO kafka.network.Processor - Closing socket
> > connection to /172.23.44.4.
> > or
> > [kafka-processor-9092-1] INFO kafka.network.Processor - Closing socket
> > connection to /172.23.44.4.
> >
> > Do anyone know what that means???
> >
> > (By the way, the IP isn't something in my network...)
> >
> > I'm using kafka 0.8.1.1 with scala 2.9.2
> >
> > thank for your help!
> >
> > Here is my log:
> >
> > [2014-06-10 18:43:58,332] 612950 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
> > > [TopicChangeListener on Controller 1]: New topics:
> > > [Set(REG_USER_TRACKING_LOG)], deleted topics: [Set()], new partition
> > > replica assignment [Map([REG_USER_TRACKING_LOG,0] -> List(1, 3, 2))]
> > > [2014-06-10 18:43:58,333] 612951 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.KafkaController - [Controller 1]: New topic
> > > creation callback for [REG_USER_TRACKING_LOG,0]
> > > [2014-06-10 18:43:58,336] 612954 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.KafkaController - [Controller 1]: New partition
> > > creation callback for [REG_USER_TRACKING_LOG,0]
> > > [2014-06-10 18:43:58,337] 612955 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.PartitionStateMachine - [Partition state
> machine on
> > > Controller 1]: Invoking state change to NewPartition for partitions
> > > [REG_USER_TRACKING_LOG,0]
> > > [2014-06-10 18:43:58,347] 612965 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> > > controller 1]: Invoking state change to NewReplica for replicas
> > >
> [Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=1],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=3],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=2]
> > > [2014-06-10 18:43:58,352] 612970 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.PartitionStateMachine - [Partition state
> machine on
> > > Controller 1]: Invoking state change to OnlinePartition for partitions
> > > [REG_USER_TRACKING_LOG,0]
> > > [2014-06-10 18:43:58,470] 613088 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> > > controller 1]: Invoking state change to OnlineReplica for replicas
> > >
> [Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=1],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=3],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=2]
> > > [2014-06-10 18:43:58,478] 613096 [kafka-request-handler-1] INFO
> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
> broker 1]
> > > Removed fetcher for partitions [REG_USER_TRACKING_LOG,0]
> > > [2014-06-10 18:43:58,533] 613151 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:43:58,538] 613156 [kafka-request-handler-1] INFO
> > > kafka.log.Log - Completed load of log REG_USER_TRACKING_LOG-0 with
> log
> > > end offset 0
> > > [2014-06-10 18:43:58,546] 613164 [kafka-request-handler-1] INFO
> > > kafka.log.LogManager - Created log for partition
> > > [REG_USER_TRACKING_LOG,0] in /var/spool/kafka with properties
> > > {segment.index.bytes -> 10485760, file.delete.delay.ms -> 60000,
> > > segment.bytes -> 536870912, flush.ms -> 9223372036854775807,
> > > delete.retention.ms -> 86400000, index.interval.bytes -> 4096,
> > > retention.bytes -> -1, cleanup.policy -> delete, segment.ms ->
> 604800000,
> > > max.message.bytes -> 1000012, flush.messages -> 9223372036854775807,
> > > min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
> > > [2014-06-10 18:43:58,547] 613165 [kafka-request-handler-1] WARN
> > > kafka.cluster.Partition - Partition [REG_USER_TRACKING_LOG,0] on
> broker
> > > 1: No checkpointed highwatermark is found for partition
> > > [REG_USER_TRACKING_LOG,0]
> > > [2014-06-10 18:43:59,372] 613990 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:43:59,577] 614195 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:43:59,782] 614400 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:43:59,988] 614606 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:00,622] 615240 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:01,033] 615651 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:01,115] 615733 [kafka-request-handler-3] INFO
> > > kafka.admin.AdminUtils$ - Topic creation
> > > {"version":1,"partitions":{"0":[3,1,2]}}
> > > [2014-06-10 18:44:01,140] 615758 [kafka-request-handler-3] INFO
> > > kafka.server.KafkaApis - [KafkaApi-1] Auto creation of topic
> > > RULE_RECRIMINATION with 1 partitions and replication factor 3 is
> successful!
> > > [2014-06-10 18:44:01,141] 615759 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:01,150] 615768 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
> > > [TopicChangeListener on Controller 1]: New topics:
> > > [Set(RULE_RECRIMINATION)], deleted topics: [Set()], new partition
> replica
> > > assignment [Map([RULE_RECRIMINATION,0] -> List(3, 1, 2))]
> > > [2014-06-10 18:44:01,150] 615768 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.KafkaController - [Controller 1]: New topic
> > > creation callback for [RULE_RECRIMINATION,0]
> > > [2014-06-10 18:44:01,151] 615769 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.KafkaController - [Controller 1]: New partition
> > > creation callback for [RULE_RECRIMINATION,0]
> > > [2014-06-10 18:44:01,151] 615769 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.PartitionStateMachine - [Partition state
> machine on
> > > Controller 1]: Invoking state change to NewPartition for partitions
> > > [RULE_RECRIMINATION,0]
> > > [2014-06-10 18:44:01,157] 615775 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> > > controller 1]: Invoking state change to NewReplica for replicas
> > >
> [Topic=RULE_RECRIMINATION,Partition=0,Replica=3],[Topic=RULE_RECRIMINATION,Partition=0,Replica=1],[Topic=RULE_RECRIMINATION,Partition=0,Replica=2]
> > > [2014-06-10 18:44:01,159] 615777 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.PartitionStateMachine - [Partition state
> machine on
> > > Controller 1]: Invoking state change to OnlinePartition for partitions
> > > [RULE_RECRIMINATION,0]
> > > [2014-06-10 18:44:01,223] 615841 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> > > controller 1]: Invoking state change to OnlineReplica for replicas
> > >
> [Topic=RULE_RECRIMINATION,Partition=0,Replica=3],[Topic=RULE_RECRIMINATION,Partition=0,Replica=1],[Topic=RULE_RECRIMINATION,Partition=0,Replica=2]
> > > [2014-06-10 18:44:01,231] 615849 [kafka-request-handler-6] INFO
> > > kafka.log.Log - Completed load of log RULE_RECRIMINATION-0 with log
> end
> > > offset 0
> > > [2014-06-10 18:44:01,232] 615850 [kafka-request-handler-6] INFO
> > > kafka.log.LogManager - Created log for partition
> [RULE_RECRIMINATION,0]
> > > in /var/spool/kafka with properties {segment.index.bytes -> 10485760,
> > > file.delete.delay.ms -> 60000, segment.bytes -> 536870912, flush.ms ->
> > > 9223372036854775807, delete.retention.ms -> 86400000,
> > > index.interval.bytes -> 4096, retention.bytes -> -1, cleanup.policy ->
> > > delete, segment.ms -> 604800000, max.message.bytes -> 1000012,
> > > flush.messages -> 9223372036854775807, min.cleanable.dirty.ratio ->
> 0.5,
> > > retention.ms -> 604800000}.
> > > [2014-06-10 18:44:01,233] 615851 [kafka-request-handler-6] WARN
> > > kafka.cluster.Partition - Partition [RULE_RECRIMINATION,0] on broker
> 1:
> > > No checkpointed highwatermark is found for partition
> [RULE_RECRIMINATION,0]
> > > [2014-06-10 18:44:01,235] 615853 [kafka-request-handler-6] INFO
> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
> broker 1]
> > > Removed fetcher for partitions [RULE_RECRIMINATION,0]
> > > [2014-06-10 18:44:01,238] 615856 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:01,239] 615857 [kafka-request-handler-6] INFO
> > > kafka.log.Log - Truncating log RULE_RECRIMINATION-0 to offset 0.
> > > [2014-06-10 18:44:01,265] 615883 [ReplicaFetcherThread-0-3] INFO
> > > kafka.server.ReplicaFetcherThread - [ReplicaFetcherThread-0-3],
> Starting
> > > [2014-06-10 18:44:01,270] 615888 [kafka-request-handler-6] INFO
> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
> broker 1]
> > > Added fetcher for partitions ArrayBuffer([[RULE_RECRIMINATION,0],
> > > initOffset 0 to broker id:3,host:kaf3,port:9092] )
> > > [2014-06-10 18:44:01,344] 615962 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:01,354] 615972 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:01,549] 616167 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:01,649] 616267 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:01,986] 616604 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:02,470] 617088 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:02,610] 617228 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:02,818] 617436 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:03,025] 617643 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:03,194] 617812 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:03,233] 617851 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:03,649] 618267 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:04,015] 618633 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:04,064] 618682 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:04,272] 618890 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:04,480] 619098 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:04,526] 619144 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:04,634] 619252 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:04,731] 619349 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:04,936] 619554 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:05,141] 619759 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:05,308] 619926 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:05,346] 619964 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:05,456] 620074 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:05,516] 620134 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:05,723] 620341 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:06,687] 621305 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:07,175] 621793 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:07,381] 621999 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:07,397] 622015 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:07,796] 622414 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:08,217] 622835 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:08,328] 622946 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:09,041] 623659 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:09,152] 623770 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:10,074] 624692 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:10,176] 624794 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:10,380] 624998 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:10,488] 625106 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:10,585] 625203 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:10,694] 625312 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:10,790] 625408 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:11,200] 625818 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:11,613] 626231 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:11,731] 626349 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:58,282] 672900 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
> > > [TopicChangeListener on Controller 1]: New topics:
> > > [Set(KAFKA_LOGGING_MESSAGE)], deleted topics: [Set()], new partition
> > > replica assignment [Map([KAFKA_LOGGING_MESSAGE,0] -> List(3, 1, 2))]
> > > [2014-06-10 18:44:58,282] 672900 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.KafkaController - [Controller 1]: New topic
> > > creation callback for [KAFKA_LOGGING_MESSAGE,0]
> > > [2014-06-10 18:44:58,283] 672901 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.KafkaController - [Controller 1]: New partition
> > > creation callback for [KAFKA_LOGGING_MESSAGE,0]
> > > [2014-06-10 18:44:58,283] 672901 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.PartitionStateMachine - [Partition state
> machine on
> > > Controller 1]: Invoking state change to NewPartition for partitions
> > > [KAFKA_LOGGING_MESSAGE,0]
> > > [2014-06-10 18:44:58,287] 672905 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:58,287] 672905 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> > > controller 1]: Invoking state change to NewReplica for replicas
> > >
> [Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=3],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=1],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=2]
> > > [2014-06-10 18:44:58,292] 672910 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.PartitionStateMachine - [Partition state
> machine on
> > > Controller 1]: Invoking state change to OnlinePartition for partitions
> > > [KAFKA_LOGGING_MESSAGE,0]
> > > [2014-06-10 18:44:58,351] 672969 [
> > > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1
> ]
> > > INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> > > controller 1]: Invoking state change to OnlineReplica for replicas
> > >
> [Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=3],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=1],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=2]
> > > [2014-06-10 18:44:58,362] 672980 [kafka-request-handler-1] INFO
> > > kafka.log.Log - Completed load of log KAFKA_LOGGING_MESSAGE-0 with
> log
> > > end offset 0
> > > [2014-06-10 18:44:58,367] 672985 [kafka-request-handler-1] INFO
> > > kafka.log.LogManager - Created log for partition
> > > [KAFKA_LOGGING_MESSAGE,0] in /var/spool/kafka with properties
> > > {segment.index.bytes -> 10485760, file.delete.delay.ms -> 60000,
> > > segment.bytes -> 536870912, flush.ms -> 9223372036854775807,
> > > delete.retention.ms -> 86400000, index.interval.bytes -> 4096,
> > > retention.bytes -> -1, cleanup.policy -> delete, segment.ms ->
> 604800000,
> > > max.message.bytes -> 1000012, flush.messages -> 9223372036854775807,
> > > min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
> > > [2014-06-10 18:44:58,374] 672992 [kafka-request-handler-1] WARN
> > > kafka.cluster.Partition - Partition [KAFKA_LOGGING_MESSAGE,0] on
> broker
> > > 1: No checkpointed highwatermark is found for partition
> > > [KAFKA_LOGGING_MESSAGE,0]
> > > [2014-06-10 18:44:58,375] 672993 [kafka-request-handler-1] INFO
> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
> broker 1]
> > > Removed fetcher for partitions [KAFKA_LOGGING_MESSAGE,0]
> > > [2014-06-10 18:44:58,376] 672994 [kafka-request-handler-1] INFO
> > > kafka.log.Log - Truncating log KAFKA_LOGGING_MESSAGE-0 to offset 0.
> > > [2014-06-10 18:44:58,377] 672995 [kafka-request-handler-1] INFO
> > > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on
> broker 1]
> > > Added fetcher for partitions ArrayBuffer([[KAFKA_LOGGING_MESSAGE,0],
> > > initOffset 0 to broker id:3,host:kaf3,port:9092] )
> > > [2014-06-10 18:44:58,706] 673324 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:58,911] 673529 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:59,116] 673734 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:59,321] 673939 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:59,526] 674144 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:44:59,938] 674556 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:00,143] 674761 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:00,554] 675172 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:01,171] 675789 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:01,581] 676199 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:01,934] 676552 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:02,345] 676963 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:02,550] 677168 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:02,756] 677374 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:03,434] 678052 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:03,988] 678606 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:04,464] 679082 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:04,605] 679223 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:04,670] 679288 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:05,226] 679844 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:05,491] 680109 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:06,048] 680666 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:06,254] 680872 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:06,459] 681077 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:06,518] 681136 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:07,485] 682103 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:07,690] 682308 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:07,955] 682573 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:08,101] 682719 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:08,570] 683188 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:08,722] 683340 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:09,139] 683757 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:09,345] 683963 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:09,550] 684168 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:10,989] 685607 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:11,401] 686019 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:45:11,605] 686223 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:04,680] 1099298 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:05,090] 1099708 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:05,704] 1100322 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:05,909] 1100527 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:06,935] 1101553 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:07,455] 1102073 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:07,998] 1102616 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:08,163] 1102781 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:08,411] 1103029 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:08,823] 1103441 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:09,030] 1103648 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:09,089] 1103707 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:09,236] 1103854 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:09,391] 1104009 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:09,442] 1104060 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:09,595] 1104213 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:09,903] 1104521 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:10,061] 1104679 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:10,266] 1104884 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:10,311] 1104929 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:10,416] 1105034 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:10,620] 1105238 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:10,884] 1105502 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:11,296] 1105914 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:11,741] 1106359 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:11,945] 1106563 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:12,051] 1106669 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:12,324] 1106942 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:12,459] 1107077 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:12,529] 1107147 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:12,736] 1107354 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:12,941] 1107559 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:13,147] 1107765 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:13,375] 1107993 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:13,481] 1108099 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:13,559] 1108177 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:13,579] 1108197 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:13,686] 1108304 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:13,764] 1108382 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:13,782] 1108400 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:14,176] 1108794 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:14,191] 1108809 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:14,793] 1109411 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:15,204] 1109822 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:15,211] 1109829 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:15,823] 1110441 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:16,029] 1110647 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:16,645] 1111263 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:16,850] 1111468 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:17,053] 1111671 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:54,009] 1148627 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:55,440] 1150058 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:56,054] 1150672 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:56,258] 1150876 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:56,668] 1151286 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:57,445] 1152063 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:57,853] 1152471 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:58,261] 1152879 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:58,466] 1153084 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:58,670] 1153288 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:58,711] 1153329 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:59,283] 1153901 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:52:59,488] 1154106 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:00,100] 1154718 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:01,165] 1155783 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:01,325] 1155943 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:01,369] 1155987 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:01,778] 1156396 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:02,187] 1156805 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:02,550] 1157168 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:02,594] 1157212 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:02,958] 1157576 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:03,367] 1157985 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:03,616] 1158234 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:03,979] 1158597 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:04,388] 1159006 [kafka-processor-9092-0] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > > [2014-06-10 18:53:04,796] 1159414 [kafka-processor-9092-1] INFO
> > > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> >
> >
> >
> >
> > François Langelier
> > Étudiant en génie Logiciel - École de Technologie Supérieure
> > <http://www.etsmtl.ca/>
> > Capitaine Club Capra <http://capra.etsmtl.ca/>
> > VP-Communication - CS Games <http://csgames.org> 2014
> > Jeux de Génie <http://www.jdgets.com/> 2011 à 2014
> > Argentier Fraternité du Piranha <http://fraternitedupiranha.com/>
> 2012-2014
> > Comité Organisateur Olympiades ÉTS 2012
> > Compétition Québécoise d'Ingénierie 2012 - Compétition Senior
>
>
Re: spam of [kafka-processor-9092-0] INFO kafka.network.Processor -
Closing socket connection to /172.23.44.4.
Posted by Joel Koshy <jj...@gmail.com>.
The broker logs that whenever it closes a connection to a client
(e.g., if there was an error or the client decides to close its
connection after talking to the broker).
If you enable TRACE level on kafka.request.logger you can see
precisely what requests are coming in.
Joel
On Tue, Jun 10, 2014 at 03:45:23PM -0400, François Langelier wrote:
> Hi all!
>
> I have 3 brokers and I keep getting this message:
> [kafka-processor-9092-0] INFO kafka.network.Processor - Closing socket
> connection to /172.23.44.4.
> or
> [kafka-processor-9092-1] INFO kafka.network.Processor - Closing socket
> connection to /172.23.44.4.
>
> Do anyone know what that means???
>
> (By the way, the IP isn't something in my network...)
>
> I'm using kafka 0.8.1.1 with scala 2.9.2
>
> thank for your help!
>
> Here is my log:
>
> [2014-06-10 18:43:58,332] 612950 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
> > [TopicChangeListener on Controller 1]: New topics:
> > [Set(REG_USER_TRACKING_LOG)], deleted topics: [Set()], new partition
> > replica assignment [Map([REG_USER_TRACKING_LOG,0] -> List(1, 3, 2))]
> > [2014-06-10 18:43:58,333] 612951 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.KafkaController - [Controller 1]: New topic
> > creation callback for [REG_USER_TRACKING_LOG,0]
> > [2014-06-10 18:43:58,336] 612954 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.KafkaController - [Controller 1]: New partition
> > creation callback for [REG_USER_TRACKING_LOG,0]
> > [2014-06-10 18:43:58,337] 612955 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.PartitionStateMachine - [Partition state machine on
> > Controller 1]: Invoking state change to NewPartition for partitions
> > [REG_USER_TRACKING_LOG,0]
> > [2014-06-10 18:43:58,347] 612965 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> > controller 1]: Invoking state change to NewReplica for replicas
> > [Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=1],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=3],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=2]
> > [2014-06-10 18:43:58,352] 612970 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.PartitionStateMachine - [Partition state machine on
> > Controller 1]: Invoking state change to OnlinePartition for partitions
> > [REG_USER_TRACKING_LOG,0]
> > [2014-06-10 18:43:58,470] 613088 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> > controller 1]: Invoking state change to OnlineReplica for replicas
> > [Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=1],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=3],[Topic=REG_USER_TRACKING_LOG,Partition=0,Replica=2]
> > [2014-06-10 18:43:58,478] 613096 [kafka-request-handler-1] INFO
> > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 1]
> > Removed fetcher for partitions [REG_USER_TRACKING_LOG,0]
> > [2014-06-10 18:43:58,533] 613151 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:43:58,538] 613156 [kafka-request-handler-1] INFO
> > kafka.log.Log - Completed load of log REG_USER_TRACKING_LOG-0 with log
> > end offset 0
> > [2014-06-10 18:43:58,546] 613164 [kafka-request-handler-1] INFO
> > kafka.log.LogManager - Created log for partition
> > [REG_USER_TRACKING_LOG,0] in /var/spool/kafka with properties
> > {segment.index.bytes -> 10485760, file.delete.delay.ms -> 60000,
> > segment.bytes -> 536870912, flush.ms -> 9223372036854775807,
> > delete.retention.ms -> 86400000, index.interval.bytes -> 4096,
> > retention.bytes -> -1, cleanup.policy -> delete, segment.ms -> 604800000,
> > max.message.bytes -> 1000012, flush.messages -> 9223372036854775807,
> > min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
> > [2014-06-10 18:43:58,547] 613165 [kafka-request-handler-1] WARN
> > kafka.cluster.Partition - Partition [REG_USER_TRACKING_LOG,0] on broker
> > 1: No checkpointed highwatermark is found for partition
> > [REG_USER_TRACKING_LOG,0]
> > [2014-06-10 18:43:59,372] 613990 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:43:59,577] 614195 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:43:59,782] 614400 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:43:59,988] 614606 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:00,622] 615240 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:01,033] 615651 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:01,115] 615733 [kafka-request-handler-3] INFO
> > kafka.admin.AdminUtils$ - Topic creation
> > {"version":1,"partitions":{"0":[3,1,2]}}
> > [2014-06-10 18:44:01,140] 615758 [kafka-request-handler-3] INFO
> > kafka.server.KafkaApis - [KafkaApi-1] Auto creation of topic
> > RULE_RECRIMINATION with 1 partitions and replication factor 3 is successful!
> > [2014-06-10 18:44:01,141] 615759 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:01,150] 615768 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
> > [TopicChangeListener on Controller 1]: New topics:
> > [Set(RULE_RECRIMINATION)], deleted topics: [Set()], new partition replica
> > assignment [Map([RULE_RECRIMINATION,0] -> List(3, 1, 2))]
> > [2014-06-10 18:44:01,150] 615768 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.KafkaController - [Controller 1]: New topic
> > creation callback for [RULE_RECRIMINATION,0]
> > [2014-06-10 18:44:01,151] 615769 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.KafkaController - [Controller 1]: New partition
> > creation callback for [RULE_RECRIMINATION,0]
> > [2014-06-10 18:44:01,151] 615769 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.PartitionStateMachine - [Partition state machine on
> > Controller 1]: Invoking state change to NewPartition for partitions
> > [RULE_RECRIMINATION,0]
> > [2014-06-10 18:44:01,157] 615775 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> > controller 1]: Invoking state change to NewReplica for replicas
> > [Topic=RULE_RECRIMINATION,Partition=0,Replica=3],[Topic=RULE_RECRIMINATION,Partition=0,Replica=1],[Topic=RULE_RECRIMINATION,Partition=0,Replica=2]
> > [2014-06-10 18:44:01,159] 615777 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.PartitionStateMachine - [Partition state machine on
> > Controller 1]: Invoking state change to OnlinePartition for partitions
> > [RULE_RECRIMINATION,0]
> > [2014-06-10 18:44:01,223] 615841 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> > controller 1]: Invoking state change to OnlineReplica for replicas
> > [Topic=RULE_RECRIMINATION,Partition=0,Replica=3],[Topic=RULE_RECRIMINATION,Partition=0,Replica=1],[Topic=RULE_RECRIMINATION,Partition=0,Replica=2]
> > [2014-06-10 18:44:01,231] 615849 [kafka-request-handler-6] INFO
> > kafka.log.Log - Completed load of log RULE_RECRIMINATION-0 with log end
> > offset 0
> > [2014-06-10 18:44:01,232] 615850 [kafka-request-handler-6] INFO
> > kafka.log.LogManager - Created log for partition [RULE_RECRIMINATION,0]
> > in /var/spool/kafka with properties {segment.index.bytes -> 10485760,
> > file.delete.delay.ms -> 60000, segment.bytes -> 536870912, flush.ms ->
> > 9223372036854775807, delete.retention.ms -> 86400000,
> > index.interval.bytes -> 4096, retention.bytes -> -1, cleanup.policy ->
> > delete, segment.ms -> 604800000, max.message.bytes -> 1000012,
> > flush.messages -> 9223372036854775807, min.cleanable.dirty.ratio -> 0.5,
> > retention.ms -> 604800000}.
> > [2014-06-10 18:44:01,233] 615851 [kafka-request-handler-6] WARN
> > kafka.cluster.Partition - Partition [RULE_RECRIMINATION,0] on broker 1:
> > No checkpointed highwatermark is found for partition [RULE_RECRIMINATION,0]
> > [2014-06-10 18:44:01,235] 615853 [kafka-request-handler-6] INFO
> > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 1]
> > Removed fetcher for partitions [RULE_RECRIMINATION,0]
> > [2014-06-10 18:44:01,238] 615856 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:01,239] 615857 [kafka-request-handler-6] INFO
> > kafka.log.Log - Truncating log RULE_RECRIMINATION-0 to offset 0.
> > [2014-06-10 18:44:01,265] 615883 [ReplicaFetcherThread-0-3] INFO
> > kafka.server.ReplicaFetcherThread - [ReplicaFetcherThread-0-3], Starting
> > [2014-06-10 18:44:01,270] 615888 [kafka-request-handler-6] INFO
> > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 1]
> > Added fetcher for partitions ArrayBuffer([[RULE_RECRIMINATION,0],
> > initOffset 0 to broker id:3,host:kaf3,port:9092] )
> > [2014-06-10 18:44:01,344] 615962 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:01,354] 615972 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:01,549] 616167 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:01,649] 616267 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:01,986] 616604 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:02,470] 617088 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:02,610] 617228 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:02,818] 617436 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:03,025] 617643 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:03,194] 617812 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:03,233] 617851 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:03,649] 618267 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:04,015] 618633 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:04,064] 618682 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:04,272] 618890 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:04,480] 619098 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:04,526] 619144 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:04,634] 619252 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:04,731] 619349 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:04,936] 619554 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:05,141] 619759 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:05,308] 619926 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:05,346] 619964 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:05,456] 620074 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:05,516] 620134 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:05,723] 620341 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:06,687] 621305 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:07,175] 621793 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:07,381] 621999 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:07,397] 622015 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:07,796] 622414 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:08,217] 622835 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:08,328] 622946 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:09,041] 623659 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:09,152] 623770 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:10,074] 624692 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:10,176] 624794 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:10,380] 624998 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:10,488] 625106 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:10,585] 625203 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:10,694] 625312 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:10,790] 625408 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:11,200] 625818 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:11,613] 626231 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:11,731] 626349 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:58,282] 672900 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.PartitionStateMachine$TopicChangeListener -
> > [TopicChangeListener on Controller 1]: New topics:
> > [Set(KAFKA_LOGGING_MESSAGE)], deleted topics: [Set()], new partition
> > replica assignment [Map([KAFKA_LOGGING_MESSAGE,0] -> List(3, 1, 2))]
> > [2014-06-10 18:44:58,282] 672900 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.KafkaController - [Controller 1]: New topic
> > creation callback for [KAFKA_LOGGING_MESSAGE,0]
> > [2014-06-10 18:44:58,283] 672901 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.KafkaController - [Controller 1]: New partition
> > creation callback for [KAFKA_LOGGING_MESSAGE,0]
> > [2014-06-10 18:44:58,283] 672901 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.PartitionStateMachine - [Partition state machine on
> > Controller 1]: Invoking state change to NewPartition for partitions
> > [KAFKA_LOGGING_MESSAGE,0]
> > [2014-06-10 18:44:58,287] 672905 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:58,287] 672905 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> > controller 1]: Invoking state change to NewReplica for replicas
> > [Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=3],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=1],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=2]
> > [2014-06-10 18:44:58,292] 672910 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.PartitionStateMachine - [Partition state machine on
> > Controller 1]: Invoking state change to OnlinePartition for partitions
> > [KAFKA_LOGGING_MESSAGE,0]
> > [2014-06-10 18:44:58,351] 672969 [
> > ZkClient-EventThread-14-one.backup.zk.three.qa:2181,
> > two.backup.zk.three.qa:2181,three.backup.zk.three.qa:2181/kafka0.8.1.1]
> > INFO kafka.controller.ReplicaStateMachine - [Replica state machine on
> > controller 1]: Invoking state change to OnlineReplica for replicas
> > [Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=3],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=1],[Topic=KAFKA_LOGGING_MESSAGE,Partition=0,Replica=2]
> > [2014-06-10 18:44:58,362] 672980 [kafka-request-handler-1] INFO
> > kafka.log.Log - Completed load of log KAFKA_LOGGING_MESSAGE-0 with log
> > end offset 0
> > [2014-06-10 18:44:58,367] 672985 [kafka-request-handler-1] INFO
> > kafka.log.LogManager - Created log for partition
> > [KAFKA_LOGGING_MESSAGE,0] in /var/spool/kafka with properties
> > {segment.index.bytes -> 10485760, file.delete.delay.ms -> 60000,
> > segment.bytes -> 536870912, flush.ms -> 9223372036854775807,
> > delete.retention.ms -> 86400000, index.interval.bytes -> 4096,
> > retention.bytes -> -1, cleanup.policy -> delete, segment.ms -> 604800000,
> > max.message.bytes -> 1000012, flush.messages -> 9223372036854775807,
> > min.cleanable.dirty.ratio -> 0.5, retention.ms -> 604800000}.
> > [2014-06-10 18:44:58,374] 672992 [kafka-request-handler-1] WARN
> > kafka.cluster.Partition - Partition [KAFKA_LOGGING_MESSAGE,0] on broker
> > 1: No checkpointed highwatermark is found for partition
> > [KAFKA_LOGGING_MESSAGE,0]
> > [2014-06-10 18:44:58,375] 672993 [kafka-request-handler-1] INFO
> > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 1]
> > Removed fetcher for partitions [KAFKA_LOGGING_MESSAGE,0]
> > [2014-06-10 18:44:58,376] 672994 [kafka-request-handler-1] INFO
> > kafka.log.Log - Truncating log KAFKA_LOGGING_MESSAGE-0 to offset 0.
> > [2014-06-10 18:44:58,377] 672995 [kafka-request-handler-1] INFO
> > kafka.server.ReplicaFetcherManager - [ReplicaFetcherManager on broker 1]
> > Added fetcher for partitions ArrayBuffer([[KAFKA_LOGGING_MESSAGE,0],
> > initOffset 0 to broker id:3,host:kaf3,port:9092] )
> > [2014-06-10 18:44:58,706] 673324 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:58,911] 673529 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:59,116] 673734 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:59,321] 673939 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:59,526] 674144 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:44:59,938] 674556 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:00,143] 674761 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:00,554] 675172 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:01,171] 675789 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:01,581] 676199 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:01,934] 676552 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:02,345] 676963 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:02,550] 677168 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:02,756] 677374 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:03,434] 678052 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:03,988] 678606 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:04,464] 679082 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:04,605] 679223 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:04,670] 679288 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:05,226] 679844 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:05,491] 680109 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:06,048] 680666 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:06,254] 680872 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:06,459] 681077 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:06,518] 681136 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:07,485] 682103 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:07,690] 682308 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:07,955] 682573 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:08,101] 682719 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:08,570] 683188 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:08,722] 683340 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:09,139] 683757 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:09,345] 683963 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:09,550] 684168 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:10,989] 685607 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:11,401] 686019 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:45:11,605] 686223 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:04,680] 1099298 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:05,090] 1099708 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:05,704] 1100322 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:05,909] 1100527 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:06,935] 1101553 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:07,455] 1102073 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:07,998] 1102616 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:08,163] 1102781 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:08,411] 1103029 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:08,823] 1103441 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:09,030] 1103648 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:09,089] 1103707 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:09,236] 1103854 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:09,391] 1104009 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:09,442] 1104060 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:09,595] 1104213 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:09,903] 1104521 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:10,061] 1104679 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:10,266] 1104884 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:10,311] 1104929 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:10,416] 1105034 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:10,620] 1105238 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:10,884] 1105502 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:11,296] 1105914 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:11,741] 1106359 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:11,945] 1106563 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:12,051] 1106669 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:12,324] 1106942 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:12,459] 1107077 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:12,529] 1107147 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:12,736] 1107354 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:12,941] 1107559 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:13,147] 1107765 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:13,375] 1107993 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:13,481] 1108099 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:13,559] 1108177 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:13,579] 1108197 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:13,686] 1108304 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:13,764] 1108382 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:13,782] 1108400 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:14,176] 1108794 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:14,191] 1108809 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:14,793] 1109411 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:15,204] 1109822 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:15,211] 1109829 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:15,823] 1110441 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:16,029] 1110647 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:16,645] 1111263 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:16,850] 1111468 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:17,053] 1111671 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:54,009] 1148627 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:55,440] 1150058 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:56,054] 1150672 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:56,258] 1150876 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:56,668] 1151286 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:57,445] 1152063 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:57,853] 1152471 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:58,261] 1152879 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:58,466] 1153084 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:58,670] 1153288 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:58,711] 1153329 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:59,283] 1153901 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:52:59,488] 1154106 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:00,100] 1154718 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:01,165] 1155783 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:01,325] 1155943 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:01,369] 1155987 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:01,778] 1156396 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:02,187] 1156805 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:02,550] 1157168 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:02,594] 1157212 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:02,958] 1157576 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:03,367] 1157985 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:03,616] 1158234 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:03,979] 1158597 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:04,388] 1159006 [kafka-processor-9092-0] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
> > [2014-06-10 18:53:04,796] 1159414 [kafka-processor-9092-1] INFO
> > kafka.network.Processor - Closing socket connection to /172.23.44.4.
>
>
>
>
> François Langelier
> Étudiant en génie Logiciel - École de Technologie Supérieure
> <http://www.etsmtl.ca/>
> Capitaine Club Capra <http://capra.etsmtl.ca/>
> VP-Communication - CS Games <http://csgames.org> 2014
> Jeux de Génie <http://www.jdgets.com/> 2011 à 2014
> Argentier Fraternité du Piranha <http://fraternitedupiranha.com/> 2012-2014
> Comité Organisateur Olympiades ÉTS 2012
> Compétition Québécoise d'Ingénierie 2012 - Compétition Senior