Resultados de la búsqueda a petición "kafka-consumer-api"
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 ...
¿Cómo funciona kafka consumer auto commit?
Estoy leyendoéste [https://www.safaribooksonline.com/library/view/kafka-the-definitive/9781491936153/ch04.html#callout_kafka_consumers__reading_data_from_kafka_CO2-1] : Confirmación automática La forma más fácil de confirmar las compensaciones ...
Filtrado de flujos de Kafka: ¿corredor o consumidor?
Estoy mirando las corrientes de kafka. Quiero filtrar mi flujo, usando un filtro con muy baja selectividad (uno en unos pocos miles). Estaba mirando este ...
Diferencia entre session.timeout.ms y max.poll.interval.ms para Kafka 0.10.0.0 y versiones posteriores
No estoy claro por qué necesitamos ambossession.timeout.ms ymax.poll.interval.ms y cuando usaríamos uno u otro o ambos? Parece que ambos indican que el límite superior en el coordinador de tiempo esperará para obtener el latido del consumidor ...
Política óptima de retención y eliminación de Kafka
Soy bastante nuevo en kafka, así que perdóname si esta pregunta es trivial. Tengo una configuración muy simple para propósitos de pruebas de tiempo como sigue: Máquina A -> escribe en el tema 1 (Intermediario) -> Máquina B lee del tema 1 Máquina ...
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 / ...
¿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 ...
diferencia entre groupid y consumerid en Kafka consumidor
Soy nuevo en Kafka. Noté en la configuración del consumidor que tiene dos identificadores. uno es group.id (obligatorio) y el segundo es consumer.id (no obligatorio). Indique por qué 2 ID y diferencia.
Kafka Streams no incrementa el desplazamiento en 1 al producir el tema
He implementado un sencillo procesador de registros de letras muertas de Kafka. Funciona perfectamente cuando se utilizan registros producidos por el productor de la consola. Sin embargo, encuentro que nuestras aplicaciones de Kafka Streams no ...
Cómo configurar temas de Kafka para que las bases de datos como RDMS y gráficas puedan consumir un esquema de entidad interconectada en forma de eventos
Tengo un caso donde tengoInformation objetos que contienenElement objetos. Si guardo unInformation objetará que intentará encontrar preexistenteElement objetos basados en un campo de valor único; de lo contrario, insértelos.Information objetos ...