Resultados de la búsqueda a petición "kafka-consumer-api"
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 ...
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 ...
¿Por qué el consumidor de Kafka tarda tanto en comenzar a consumir?
Comenzamos un consumidor de Kafka, escuchando un tema que aún no se ha creado (aunque la creación automática de temas está habilitada). No mucho tiempo después, un productor publica mensajes sobre ese tema. Sin embargo, al consumidor le lleva ...
¿Cuál es la diferencia en Kafka entre un coordinador de grupo de consumidores y un líder de grupo de consumidores?
Veo referencias a los coordinadores de Kafka Consumer Group y a los líderes de los grupos de consumidores ... ¿Cuál es la diferencia? ¿Cuál es el beneficio de separar la administración del grupo en dos conjuntos diferentes de responsabilidades?
Cómo manejar el error y no comprometerse cuando use Kafka Streams DSL
Para Kafka Streams, si usamos una API de procesador de nivel inferior, podemos controlar la confirmación o no. Entonces, si ocurren problemas en nuestro código, y no queremos confirmar este mensaje. En este caso, Kafka reenviará este mensaje ...
Apache Kafka y Avro: org.apache.avro.generic.GenericData $ Record no se puede enviar a com.harmeetsingh13.java.Customer
Cada vez que intento leer el mensaje de la cola kafka, recibo la siguiente excepción: [error] (run-main-0) java.lang.ClassCastException: org.apache.avro.generic.GenericData$Record cannot be cast to com.harmeetsingh13.java.Customer ...
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 ...
Código de error del consumidor de alto nivel de Kafka = 15
Cuando se trata de consumir desde Kafka usando el consumidor de alto nivel (usando un grupo de consumidores completamente nuevo), el consumidor nunca comienza a funcionar. Cuando cambio el nivel de registro a depuración, puedo ver las dos líneas ...
Consumidor de kafka de primavera, ¿busca compensación en tiempo de ejecución?
Estoy usando el KafkaMessageListenerContainer para consumir del tema kafka, tengo una lógica de aplicación para procesar cada registro que también depende de otros micro servicios. Ahora estoy confirmando manualmente el desplazamiento después de ...
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 ...