Resultados de la búsqueda a petición "apache-kafka"
¿Cuándo lanza el cliente Apache Kafka una excepción de "Batch Expired"?
Usando el cliente Java Apache Kafka (0.9), estoy tratando de enviar una larga serie de registros al corredor usando elClase de productor Kafka [https://kafka.apache.org/090/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html] . El ...
¿Cómo pasar datos de Kafka a Spark Streaming?
Estoy tratando de pasar datos de kafka a la transmisión por chispa. Esto es lo que he hecho hasta ahora: Instalado amboskafka ysparkEmpezadozookeeper con configuración de propiedades predeterminadaEmpezadokafka server con configuración de ...
Conexión entre Apache Kafka y JMS
Me preguntaba si Apache Kafka podría comunicarse y enviar mensajes a JMS. ¿Puedo establecer una conexión entre ellos? Por ejemplo, estoy usando JMS en mi sistema y debería enviar mensajes al otro sistema que usa Kafka
Cómo permitir que diferentes contenedores Docker se comuniquen entre sí sin exponer los puertos al mundo entero
Necesitaba probar mikafka consumidor y desencadenantes de mensajes en un entorno controlado. Entonces hice unansible proyecto para crear un simulacrokafka servidores:mokafelk [https://github.com/xialingxiao/mokafelk]. Funciona bien, excepto que ...
¿Pueden varios consumidores de Kafka leer el mismo mensaje de la partición?
Estamos planeando escribir un consumidor Kafka (java) que lea la cola Kafka para realizar una acción que está en el mensaje. A medida que los consumidores se ejecutan independientemente, ¿el mensaje será procesado por un solo consumidor a la ...
¿Cómo configurar el registro para los productores de Kafka?
Estoy usando el cliente productor de Kafka y no tengo ninguna configuración log4j en mi proyecto. Al ejecutarse, el programa imprime muchos registros de Kafka Debug que realmente no quiero. Entonces, intenté agregar un log4j.properties para ...
kafka.consumer.SimpleConsumer: Reconectarse debido a un error de socket: java.nio.channels.ClosedChannelException
Estoy ejecutando un consumidor simple para kafka como este: int timeout = 80000; int bufferSize = 64*1024; consumer = new SimpleConsumer(host, port,timeout, bufferSize, clientName);Esto funciona bien durante un par de horas, pero recibo una ...
Kafka Crear opciones de API de tema para lenguajes no Java
Si bien puede crear un tema a través de Java o lenguajes basados en Java (consulteaquí [https://stackoverflow.com/questions/18225263/kafka-0-8-is-it-possible-to-create-topic-with-partition-and-replication-using-j] ), no parece haber una forma ...
Consumidor de Kafka Avro con problemas de decodificador
Cuando intenté correrKafka Consumer con Avro [https://gist.github.com/yaroncon/97082e0b794d83fccf12]sobre los datos con mi esquema respectivo, devuelve un error de "AvroRuntimeException: datos con formato incorrecto. La longitud es negativa: ...
¿Apache Kafka es apropiado para su uso como una cola de tareas desordenadas?
Kafka divide los mensajes entrantes en particiones, de acuerdo con la partición asignada por el productor. Los mensajes de las particiones luego son consumidos por los consumidores en diferentes grupos de consumidores. Esta arquitectura me hace ...