kafka_1 | [2019-07-14 11:04:22,060] INFO [ThrottledChannelReaper-Fetch]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
kafka_1 | [2019-07-14 11:04:22,060] INFO [ThrottledChannelReaper-Produce]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
kafka_1 | [2019-07-14 11:04:22,108] INFO [ThrottledChannelReaper-Request]: Starting (kafka.server.ClientQuotaManager$ThrottledChannelReaper)
kafka_1 | [2019-07-14 11:04:22,436] INFO Log directory /kafka/kafka-logs-574a66d1e445 not found, creating it. (kafka.log.LogManager)
kafka_1 | [2019-07-14 11:04:22,619] INFO Loading logs. (kafka.log.LogManager)
kafka_1 | [2019-07-14 11:04:22,695] INFO Logs loading complete in 76 ms. (kafka.log.LogManager)
kafka_1 | [2019-07-14 11:04:22,845] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager)
kafka_1 | [2019-07-14 11:04:22,855] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager)
kafka_1 | [2019-07-14 11:04:25,653] INFO Awaiting socket connections on s0.0.0.0:9092. (kafka.network.Acceptor)
kafka_1 | [2019-07-14 11:04:25,700] INFO [SocketServer brokerId=1004] Created data-plane acceptor and processors for endpoint : EndPoint(null,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.network.SocketServer)
kafka_1 | [2019-07-14 11:04:25,702] INFO [SocketServer brokerId=1004] Started 1 acceptor threads for data-plane (kafka.network.SocketServer)
kafka_1 | [2019-07-14 11:04:25,804] INFO [ExpirationReaper-1004-Produce]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
kafka_1 | [2019-07-14 11:04:25,806] INFO [ExpirationReaper-1004-Fetch]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
kafka_1 | [2019-07-14 11:04:25,808] INFO [ExpirationReaper-1004-DeleteRecords]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
kafka_1 | [2019-07-14 11:04:25,809] INFO [ExpirationReaper-1004-ElectPreferredLeader]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
kafka_1 | [2019-07-14 11:04:25,823] INFO [LogDirFailureHandler]: Starting (kafka.server.ReplicaManager$LogDirFailureHandler)
kafka_1 | [2019-07-14 11:04:25,899] INFO Creating /brokers/ids/1004 (is it secure? false) (kafka.zk.KafkaZkClient)
kafka_1 | [2019-07-14 11:04:26,006] INFO Stat of the created znode at /brokers/ids/1004 is: 350,350,1563102265912,1563102265912,1,0,0,72058175869812736,182,0,350
kafka_1 | (kafka.zk.KafkaZkClient)
kafka_1 | [2019-07-14 11:04:26,008] INFO Registered broker 1004 at path /brokers/ids/1004 with addresses: ArrayBuffer(EndPoint(kafka,9092,ListenerName(PLAINTEXT),PLAINTEXT)), czxid (broker epoch): 350 (kafka.zk.KafkaZkClient)
kafka_1 | [2019-07-14 11:04:26,014] WARN No meta.properties file under dir /kafka/kafka-logs-574a66d1e445/meta.properties (kafka.server.BrokerMetadataCheckpoint)
kafka_1 | [2019-07-14 11:04:26,600] INFO [ExpirationReaper-1004-topic]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
kafka_1 | [2019-07-14 11:04:26,673] INFO [ExpirationReaper-1004-Heartbeat]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
kafka_1 | [2019-07-14 11:04:26,675] INFO [ExpirationReaper-1004-Rebalance]: Starting (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
kafka_1 | [2019-07-14 11:04:26,786] INFO [GroupCoordinator 1004]: Starting up. (kafka.coordinator.group.GroupCoordinator)
kafka_1 | [2019-07-14 11:04:26,788] INFO [GroupCoordinator 1004]: Startup complete. (kafka.coordinator.group.GroupCoordinator)
kafka_1 | [2019-07-14 11:04:26,796] INFO [GroupMetadataManager brokerId=1004] Removed 0 expired offsets in 8 milliseconds. (kafka.coordinator.group.GroupMetadataManager)
kafka_1 | [2019-07-14 11:04:26,952] INFO [ProducerId Manager 1004]: Acquired new producerId block (brokerId:1004,blockStartProducerId:8000,blockEndProducerId:8999) by writing to Zk with path version 9 (kafka.coordinator.transaction.ProducerIdManager)
kafka_1 | [2019-07-14 11:04:27,139] INFO [TransactionCoordinator id=1004] Starting up. (kafka.coordinator.transaction.TransactionCoordinator)