Resultados de la búsqueda a petición "apache-kafka"
Kafka: modifique el número de particiones para un tema específico utilizando Java
Soy nuevo en Kafka y estoy trabajando con KafkaProducer y KafkaConsumer, versión: 0.9.0.1. ¿Hay alguna forma en Java de alterar / actualizar el número de particiones para un tema específico después de que se haya creado? No estoy usando ...
¿Por qué no puedo aumentar session.timeout.ms?
Quiero aumentarsession.timeout.ms para permitir más tiempo para procesar los mensajes recibidos entrepoll() llamadas. Sin embargo cuando cambiosession.timeout.ms a un valor superior a 30000, no puede crear un objeto de consumidor y arroja el ...
¿Cómo confirmar manualmente el desplazamiento en la transmisión directa de Spark Kafka?
Miré a mi alrededor con fuerza, pero no encontré una respuesta satisfactoria a esto. Tal vez me estoy perdiendo algo. Por favor ayuda. Tenemos una aplicación de transmisión de Spark que consume un tema de Kafka, que debe garantizar el ...
Kafka - problemas con TimestampExtractor
yo sueloorg.apache.kafka:kafka-streams:0.10.0.1 Estoy tratando de trabajar con una secuencia basada en series de tiempo que no parece desencadenar unaKStream.Process() desencadenar ("puntuar"). ...
Leyendo el mismo mensaje varias veces de Kafka
yo sueloSpring Kafka API [http://docs.spring.io/spring-kafka/reference/htmlsingle/#_retrying_deliverieshttp://] para implementar Kafka Consumer con gestión manual de compensación: @KafkaListener(topics = "some_topic") public void ...
Excepción al acceder a KafkaOffset desde RDD
Tengo un consumidor de Spark que se transmite desde Kafka. Estoy tratando de gestionar las compensaciones para la semántica de una sola vez. Sin embargo, al acceder al desplazamiento, arroja la siguiente ...
Kafka 0.10 Java Client TimeoutException: lote que contiene 1 registro (s) caducado
Tengo una configuración de Zookeeper / Kafka de un solo nodo, corredor múltiple (3). Estoy usando el cliente Java Kafka 0.10. Escribí el siguiente productor remoto simple (en un servidor diferente al de Kafka) (en el código reemplacé mi ...
Problemas de configuración / rendimiento del consumidor de Kafka
Estoy probando kafka como alternativa a AWS SQS. La motivación es principalmente mejorar el rendimiento donde kafka eliminaría la restricción de extraer 10 mensajes a la vez con un límite de 256kb. Aquí hay un escenario de alto nivel de mi caso ...
NoBrokersAvailable: NoBrokersAvailable-Kafka Error
Ya empecé a aprender Kafka. Intentando operaciones básicas en él. Me he quedado estancado en un punto sobre los 'Brokers'. Mi kafka se está ejecutando pero cuando quiero crear una partición. from kafka import TopicPartition (ERROR THERE) ...
Pedido de particiones múltiples Kafka
Soy consciente de que no es posible ordenar múltiples particiones en Kafka y que el orden de las particiones solo está garantizado para un solo consumidor dentro de un grupo (para una sola partición). Sin embargo, con Kafka Streams 0.10, ¿ahora ...