Resultados de la búsqueda a petición "kafka-consumer-api"
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 hacer que el productor pueda reiniciarse?
a última versión de kafka admite exactamente una vez la semántica (EoS). Para respaldar esta noción, se agregan detalles adicionales a cada mensaje. Esto significa que a su consumidor; Si imprime compensaciones de mensajes, no ...
Kafka consumidor no devuelve ningún evento
El consumidor de Scala kafka a continuación no devuelve ningún evento depoll llamada Sin embargo, el tema es correcto, y puedo ver los eventos que se envían al tema utilizando el consumidor de la ...
Obteniendo el último mensaje enviado a un tema kafka
Soy nuevo en Kafka y estoy trabajando en un prototipo para conectar un servicio de transmisión patentado a Kafka. Estoy buscando obtener la clave del último mensaje enviado sobre un tema, ya que nuestro consumidor interno de transmisiones debe ...
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 ...
¿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 ...
El conector del sumidero Kafka Connect JDBC no funciona
Estoy tratando de usar el conector de sumidero Kafka Connect JDBC para insertar datos en Oracle, pero arroja un error. He intentado con todas las configuraciones posibles del esquema. Debajo están los ejemplos. Sugiera si me falta algo a ...
Solicitar mensajes entre dos marcas de tiempo de Kafka
¿Es posible consumir mensajes de Kafka en función de un período de tiempo en el que se ingirieron los mensajes? Ejemplo: Quiero que todos los mensajes se ingieran a un tema entre 0900-1000 hoy (y ahora son 1200). Si solo hay una manera de ...
Consumidor atrapado en reingresar
He leído otros hilos y he solucionado el problema utilizando una nueva ID de grupo, sin embargo, me gustaría entender qué podría causar esto. Tengo un tema con 16 particiones, configuré session.timeout.ms = 30000 y max.poll.interval.ms = ...