Resultados de la búsqueda a petición "apache-kafka"
El consumo de Kafka falló Iterator está en estado fallido
Recibo una excepción al consumir los mensajes de kafka. org.springframework.messaging.MessagingException: Consuming from Kafka failed; nested exception is java.util.concurrent.ExecutionException: java.lang.IllegalStateException: Iterator is in ...
Throuput de consumidor lento cuando se usa la configuración de 2 consumidores
Usando la extensión spring -integration-kafka y la siguiente configuración: <int-kafka:zookeeper-connect id="zookeeperConnect" zk-connect="#{kafkaConfig['zooKeeperUrl']}" zk-connection-timeout="10000" zk-session-timeout="10000" ...
Kafka Producer - ¿Por defecto soporta Multithreading?
Soy novato en kafka. He creado ejemplos de programas de kafka sync para productores y grupos de consumidores usando kafka_2.9.2-0.8.1.1. Entonces, mi pregunta es, ¿necesito agregar código de subprocesos múltiples al productor (como lo ha hecho la ...
Algoritmo de reequilibrio del consumidor de Kafka
¿Puede alguien decirme cuál es el algoritmo de reequilibrio para los consumidores de Kafka? Me gustaría entender cómo el recuento de particiones y los hilos de consumo afectan esto. Gracias,
Java, Cómo obtener el número de mensajes en un tema en apache kafka
Estoy usando apache kafka para mensajería. He implementado el productor y el consumidor en Java. ¿Cómo podemos obtener la cantidad de mensajes en un tema?
procesamiento de registro en tiempo real usando apache spark streaming
Quiero crear un sistema donde pueda leer registros en tiempo real y usar apache spark para procesarlo. Estoy confundido si debería usar algo como kafka o canal para pasar los registros a la corriente de chispas o si debo pasar los registros con ...
Kafka en Kubernetes - Marcar al coordinador muerto para el grupo
Soy bastante nuevo en Kubernetes y quería configurar a Kafka y al cuidador del zoológico con él. Pude configurar Apache Kafka y Zookeeper en Kubernetes usando StatefulSets. Seguíesta ...
cambio del período de retención de kafka durante el tiempo de ejecución
Con Kafka 0.8.1.1, ¿cómo cambio el tiempo de retención del registro mientras se está ejecutando? losdocumentación [http://kafka.apache.org/documentation.html#brokerconfigs]dice que la propiedad eslog.retention.hours, pero tratando de cambiarlo ...
¿Cómo verificar si ZooKeeper se está ejecutando o está activo desde el símbolo del sistema?
Exploré algunas opciones para configurar kafka y supe que Zookeeper debe estar en funcionamiento para iniciar un kafka. Me gustaría saber cómo puedo encontrar lo siguiente. 1) nombre de host y puerto para mi instancia de zookeeper --- Revisé ...
Problema al conectar kafka desde afuera
Estoy usando hortonwork Sandbox para el servidor kafka tratando de conectar kafka desde eclipse con código java. Use esta configuración para conectarse al productor para enviar el ...