Resultados de la búsqueda a petición "apache-kafka"
¿Cómo enviar la salida de dos Spout diferentes al mismo Bolt?
Tengo dos Kafka Spouts cuyos valores quiero enviar al mismo rayo. Es posible ?
Colmena Crear múltiples archivos pequeños para cada inserción en HDFS
lo siguiente ya se ha logrado Kafka Producer extrae datos de Twitter usando Spark Streaming.Kafka Consumer ingiere datos en la tabla externa de Hive (en HDFS).mientras esto funciona bien hasta ahora. Solo estoy enfrentando un problema, mientras ...
Integración de Kafka Spring: los encabezados no llegan para el consumidor de kafka
Estoy usando Kafka Spring Integration para publicar y consumir mensajes usando kafka. Veo que la carga útil se pasa correctamente del productor al consumidor, pero la información del encabezado se anula en alguna ...
Kafka en Kubernetes multi-nodo
Así que mi objetivo aquí es establecer un grupo de varios corredores de kafka de manera distribuida. Pero no puedo ver la manera de que los corredores se conozcan entre sí. Por lo que yo entiendo, cada corredor necesita un ID por separado en ...
La transmisión de Apache Flink en clúster no divide los trabajos con los trabajadores
Mi objetivo es configurar un clúster de alto rendimiento utilizando Kafka como fuente y Flink como motor de procesamiento de flujo. Esto es lo que he hecho. He configurado un clúster de 2 nodos la siguiente configuración en el maestro y el ...
Kafka kafka.common.MessageSizeTooLargeException en el consumidor
Para algunos mensajes más grandes encontré el siguiente error: kafka.common.MessageSizeTooLargeException: Message size is 1185198 bytes which exceeds the maximum configured message size of 1000012.Entonces segúneste ...
¿Qué determina la compensación del consumidor de Kafka?
Soy relativamente nuevo en Kafka. He experimentado un poco con él, pero algunas cosas no me quedan claras con respecto a la compensación del consumidor. Por lo que he entendido hasta ahora, cuando un consumidor comienza, el desplazamiento desde ...
API del procesador Kafka: ¿Clave diferente para Source y StateStore?
Actualmente estamos implementando un proceso (utilizando la API del procesador Kafka) donde necesitamos combinar información de 2 eventos correlacionados (mensajes) sobre un tema y luego reenviar esa información combinada. Los eventos se originan ...
Cómo enumerar productores en kafka
Así como Kafka Offset Monitor puede mostrar una lista de consumidores activos de un tema, ¿hay alguna herramienta o interfaz de línea de comando o algo que pueda enumerar el nombre de los productores que publican sobre un tema determinado?
kafka pierde todos los temas al reiniciar
Estoy probando Kafka (0.8.2.1) en una VM, pero tengo problemas con él: aunque todo está bien mientras la máquina permanece encendida (incluso si reinicio ZK / Kafka), si reinicio la máquina (después de apagarla con gracia abajo ZK / Kafka) parece ...