centos - saeki - kafka en la orilla satoru nakata

Mi kafka siempre se apaga automáticamente, después de que comenzó un período de tiempo

Question

siempre se apaga automáticamente, pero no hay error.

registro del servidor kafka:

[2016-01-11 12: 15: 06,435] INFORMACIÓN Verificación de propiedades (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,489] INFO Property broker.id se reemplaza a 0 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,489] INFO Propiedad host.name se reemplaza a 172.16.1.22 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,490] INFO La propiedad log.cleaner.enable se reemplaza por falsa (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,490] INFO Propiedad log.dirs se reemplaza por / data / www / wifiin / logs / kafka (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,490] INFO La propiedad log.retention.check.interval.ms se reemplaza a 300000 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,491] INFORMACIÓN La propiedad log.retention.hours se reemplaza a 168 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,491] INFO La propiedad log.segment.bytes se reemplaza por 1073741824 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,491] INFO La propiedad num.io.threads se reemplaza por 8 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,491] INFO Propiedad num.network.threads se reemplaza a 3 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,492] INFO Propiedad num.partitions se reemplaza a 1 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,492] INFO La propiedad num.recovery.threads.per.data.dir se reemplaza por 1 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,492] El puerto INFO Property se reemplaza por 9092 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,493] INFO La propiedad socket.receive.buffer.bytes se reemplaza por 102400 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,493] INFO La propiedad socket.request.max.bytes se reemplaza a 104857600 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,493] INFO La propiedad socket.send.buffer.bytes se reemplaza por 102400 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,493] INFO Propiedad zookeeper.connect se reemplaza por 127.0.0.1:2181 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,494] INFO La propiedad zookeeper.connection.timeout.ms se reemplaza a 6000 (kafka.utils.VerifiableProperties)

[2016-01-11 12: 15: 06,550] INFO [Servidor Kafka 0], comenzando (kafka.server.KafkaServer)

[2016-01-11 12: 15: 06,553] INFORMACIÓN [Servidor Kafka 0], Conexión con el cuidador del zoo en 127.0.0.1:2181 (kafka.server.KafkaServer)

[2016-01-11 12: 15: 06,568] INFORMACIÓN Iniciando el hilo del evento ZkClient. (org.I0Itec.zkclient.ZkEventThread)

[2016-01-11 12: 15: 06,579] INFO Entorno del cliente: zookeeper.version = 3.4.6-1569965, integrado el 20/02/2014 09:09 GMT (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,579] INFO Entorno de cliente: host.name = wifiin-analysis-22 (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,579] INFO Entorno del cliente: java.version = 1.7.0_40 (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,579] INFO Entorno del cliente: java.vendor = Oracle Corporation (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,579] INFO Entorno del cliente: java.home = / usr / local / java / jdk1.7.0_40 / jre (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,579] INFO Entorno de cliente: java.class.path =.: / Usr / local / java / latest // lib / dt.jar: / usr / local / java / latest // lib / tools.jar: / usr / local / kafka / bin /../ core / build / dependent-libs-2.10.4 * / .jar: / usr / local / kafka / bin /../ examples / build / libs // kafka-examples .jar: / usr / local / kafka / bin /../ contrib / hadoop-consumer / compilación / libs // kafka-hadoop-consumer * .jar: / usr / local / kafka / bin / ../contrib/hadoop-producer/build/libs//kafka-hadoop-producer*.jar:/usr/local/kafka/bin/../clients/build/libs/kafka-clients*.jar:/usr /local/kafka/bin/../libs/jopt-simple-3.2.jar:/usr/local/kafka/bin/../libs/kafka_2.9.1-0.8.2.1.jar:/usr/local/kafka /bin/../libs/kafka_2.9.1-0.8.2.1-javadoc.jar:/usr/local/kafka/bin/../libs/kafka_2.9.1-0.8.2.1-scaladoc.jar:/usr/local /kafka/bin/../libs/kafka_2.9.1-0.8.2.1-sources.jar:/usr/local/kafka/bin/../libs/kafka_2.9.1-0.8.2.1-test.jar:/usr /local/kafka/bin/../libs/kafka-clients-0.8.2.1.jar:/usr/local/kafka/bin/../libs/log4j-1.2.16.jar:/usr/local/kafka /bin/../libs/lz4-1.2.0.jar:/usr/l ocal / kafka / bin /../ libs / metrics-core-2.2.0.jar: / usr / local / kafka / bin /../ libs / scala-library-2.9.1.jar: / usr / local / kafka / bin /../ libs / slf4j-api-1.7.6.jar: / usr / local / kafka / bin /../ libs / slf4j-log4j12-1.6.1.jar: / usr / local / kafka / bin /../ libs / snappy-java-1.1.1.6.jar: / usr / local / kafka / bin /../ libs / zkclient-0.3.jar: / usr / local / kafka / bin /../ libs /zookeeper-3.4.6.jar:/usr/local/kafka/bin/../core/build/libs/kafka_2.10*.jar (org.apache.zookeeper.ZooKeeper) [2016-01-11 12: 15: 06,579] INFO Entorno del cliente: java.library.path = / usr / java / packages / lib / amd64: / usr / lib64: / lib64: / lib: / usr / lib (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,580] INFO Entorno del cliente: java.io.tmpdir = / tmp (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,580] INFO Entorno del cliente: java.compiler = (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,580] INFO Entorno de cliente: os.name = Linux (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,580] INFO Entorno del cliente: os.arch = amd64 (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,580] INFO Entorno del cliente: os.version = 2.6.32-573.3.1.el6.x86_64 (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,580] INFO Entorno de cliente: user.name = root (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,580] INFO Entorno del cliente: usuario.home = / root (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,580] INFO Entorno del cliente: user.dir = / usr / local / kafka (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,581] INFO Iniciando la conexión del cliente, connectString = 127.0.0.1: 2181 sessionTimeout = 6000 watcher=org.I0Itec.zkclient.ZkClient@52d73384 (org.apache.zookeeper.ZooKeeper)

[2016-01-11 12: 15: 06,609] INFO Abrir la conexión del socket al servidor 127.0.0.1/127.0.0.1:2181. No intentará autenticarse utilizando SASL (error desconocido) (org.apache.zookeeper.ClientCnxn)

[2016-01-11 12: 15: 06,614] INFO Conexión de socket establecida a 127.0.0.1/127.0.0.1:2181, sesión de inicio (org.apache.zookeeper.ClientCnxn)

[2016-01-11 12: 15: 06,661] INFO Establecimiento de sesión completo en el servidor 127.0.0.1/127.0.0.1:2181, sessionid = 0x15210b1e3051357, tiempo de espera negociado = 6000 (org.apache.zookeeper.ClientCnxn)

[2016-01-11 12: 15: 06,664] INFO estado del guardián del zoo cambiado (SyncConnected) (org.I0Itec.zkclient.ZkClient)

[2016-01-11 12: 15: 06,915] INFO Cargando registros. (kafka.log.LogManager)

[2016-01-11 12: 15: 07,021] INFO Carga completa del registro sdkLog-0 con desplazamiento del final del registro 209376831 (kafka.log.Log)

[2016-01-11 12: 15: 07,039] INFO Registros de carga completa. (kafka.log.LogManager)

[2016-01-11 12: 15: 07,040] INFO Inicio de la limpieza del registro con un período de 300000 ms. (kafka.log.LogManager)

[2016-01-11 12: 15: 07,044] INFO Iniciar el enjuague de registro con un período predeterminado de 9223372036854775807 ms. (kafka.log.LogManager)

[2016-01-11 12: 15: 17,096] INFORMACIÓN Esperando conexiones de socket en 172.16.1.22:9092. (kafka.network.Acceptor)

[2016-01-11 12: 15: 17,097] INFO [Servidor de socket en el intermediario 0], iniciado (kafka.network.SocketServer)

[2016-01-11 12: 15: 17,195] INFO No cargará MX4J, mx4j-tools.jar no está en la ruta de clases (kafka.utils.Mx4jLoader $)

[2016-01-11 12: 15: 17,234] INFO 0 elegido exitosamente como líder (kafka.server.ZookeeperLeaderElector)

[2016-01-11 12: 15: 17,500] INFO Broker registrado 0 en path / brokers / ids / 0 con la dirección 172.16.1.22:9092. (kafka.utils.ZkUtils $)

[2016-01-11 12: 15: 17,502] INFO El nuevo líder es 0 (kafka.server.ZookeeperLeaderElector $ LeaderChangeListener)

[2016-01-11 12: 15: 17,515] INFO [Servidor Kafka 0], iniciado (kafka.server.KafkaServer)

[2016-01-11 12: 15: 17,795] INFO [ReplicaFetcherManager en el intermediario 0] Se eliminó el recopilador de particiones [sdkLog, 0] (kafka.server.ReplicaFetcherManager)

[2016-01-11 12: 15: 17,856] INFO [ReplicaFetcherManager en el intermediario 0] Se eliminó el recopilador de las particiones [sdkLog, 0] (kafka.server.ReplicaFetcherManager)

[2016-01-11 14: 47: 41,816] INFO [Servidor Kafka 0], cerrando (kafka.server.KafkaServer)

[2016-01-11 14: 47: 41,818] INFO [Servidor Kafka 0], Inicio de apagado controlado (kafka.server.KafkaServer)

[2016-01-11 14: 47: 41,981] INFO [servidor de Kafka 0], se logró el apagado controlado (kafka.server.KafkaServer)

[2016-01-11 14: 47: 41,983] INFO Conexión del zócalo de cierre a /172.16.1.22. (kafka.network.Processor)

[2016-01-11 14: 47: 41,984] INFO [Servidor de conexión en el intermediario 0], Apagado (kafka.network.SocketServer)

[2016-01-11 14: 47: 41,989] INFO [Servidor de socket en el intermediario 0], Cierre completado (kafka.network.SocketServer)

[2016-01-11 14: 47: 41,991] INFORMACIÓN [Controlador de solicitud de Kafka en el intermediario 0], cierre (kafka.server.KafkaRequestHandlerPool)

[2016-01-11 14: 47: 41,994] INFO [Gestor de solicitudes de Kafka en el intermediario 0], cerrado por completo (kafka.server.KafkaRequestHandlerPool)

[2016-01-11 14: 47: 42,267] INFO [Administrador de réplicas en el intermediario 0]: cierre (kafka.server.ReplicaManager)

[2016-01-11 14: 47: 42,267] INFO [ReplicaFetcherManager en el intermediario 0] apagando (kafka.server.ReplicaFetcherManager)

[2016-01-11 14: 47: 42,269] INFO [ReplicaFetcherManager en el intermediario 0] finalizó el cierre (kafka.server.ReplicaFetcherManager)

[2016-01-11 14: 47: 42,314] INFO [Administrador de réplicas en el intermediario 0]: cierre por completo (kafka.server.ReplicaManager)

[2016-01-11 14: 47: 42,315] INFORMACIÓN Apagado. (kafka.log.LogManager)

[2016-01-11 14: 47: 42,376] INFO Cierre completo. (kafka.log.LogManager)

[2016-01-11 14: 47: 42,384] INFO Terminar el hilo del evento ZkClient. (org.I0Itec.zkclient.ZkEventThread)

[2016-01-11 14: 47: 42,396] SESIÓN INFO: 0x15210b1e3051357 cerrado (org.apache.zookeeper.ZooKeeper)

[2016-01-11 14: 47: 42,396] INFO EventThread shut down (org.apache.zookeeper.ClientCnxn)

[2016-01-11 14: 47: 42,396] INFO [Servidor Kafka 0], cierre completo (kafka.server.KafkaServer)

Al principio, creo que OOM-killer causa que los centos lo maten. y edito la oom_score de kafka. pero no es útil.

Ahora. ¿Qué voy a hacer?

¡Muchas gracias!

Answer 1

./kafka-server-start.sh -daemon ../config/server.properties

Esto puede ayudarte!