Resultados de la búsqueda a petición "apache-kafka"
Consumidor Kafka: ¿cuál es la relación de los procesos e hilos del consumidor con las particiones de temas?
He estado trabajando con Kafka últimamente y tengo un poco de confusión con respecto a los consumidores de un grupo de consumidores. El centro de la confusión es si implementar a los consumidores como procesos o hilos. Para esta pregunta, suponga ...
¿Por qué Kafka tan rápido [cerrado]
Si tengo el mismo hardware, para usar Kafka o nuestra solución actual (ServiceMix / Camel). ¿Hay alguna diferencia? ¿Kafka puede manejar datos "más grandes" que él? ¿Por qué? ¿Hay un artículo para hablar sobre qué tan rápido podría ser? Pero ...
Apache Kafka con consumidor de alto nivel: omita mensajes corruptos
Tengo un problema con el consumidor de kafka de alto nivel (0.8.2.0): después de consumir cierta cantidad de datos, uno de nuestros consumidores se detiene. Después de reiniciar, consume algunos mensajes y se detiene nuevamente sin error / ...
Error al crear temas de Kafka: el factor de replicación es mayor que los corredores disponibles
Estoy tratando de crear temas en Kafka siguiendo la guía en el sitio web de Apache Kafka a través de la línea de comandos. Mientras ejecuta el comando: bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 ...
usando el protocolo mqtt con kafka como agente de mensajes
¿Cómo podemos usar el protocolo mqtt con kafka como agente de mensajes? Los clientes (aplicaciones android / ios / desktop java, etc.) producirán y consumirán mensajes usando las bibliotecas del lado del cliente mqtt phao que están disponibles ...
Error de Kafka en E / S java.io.EOFException: nulo
Estoy usando Kafka 0.8.2.0 (Scala 2.10). En mis archivos de registro, veo el siguiente mensaje de forma intermitente. Esto parece un problema de conectividad, pero estoy ejecutando ambos en mi localhost. ¿Es este un mensaje de advertencia ...
¿Cómo puedo usar Kafka para retener registros en logstash por un período más largo?
Actualmente uso redis -> s3 -> búsqueda elástica -> pila de kibana para canalizar y visualizar mis registros. Pero debido al gran volumen de datos en la búsqueda elástica, puedo conservar registros hasta 7 días. Quiero traer el grupo de kafka en ...
Cómo eliminar un tema en apache kafka [duplicar]
Esta pregunta ya tiene una respuesta aquí: Eliminar tema en Kafka 0.8.1.1 [/questions/24287900/delete-topic-in-kafka-0-8-1-1] 13 respuestasNecesito eliminar un tema en kafka-0.8.2.2.3. He utilizado el siguiente comando para eliminar el ...
Kafka 0.8.2.2 - No se pueden publicar mensajes
Hemos escrito un cliente java para publicar mensajes en kafka. El código se muestra a continuación. Properties props = new ...
Kafka Streams y RPC: ¿llamar al servicio REST en el operador map () se considera un antipatrón?
El enfoque ingenuo para implementar el caso de uso de enriquecer un flujo entrante de eventos almacenados en Kafka con datos de referencia es llamarmap() operador de un API de REST de servicio externo que proporciona estos datos de referencia, ...