it-swarm-es.tech

apache-kafka

¿Kafka python API admite el procesamiento de flujo?

Kafka Consumer - Comportamiento de la encuesta

Kafka productor TimeoutException: Caducan 1 registro (s)

Kafka política óptima de retención y eliminación

Kafka: el mensaje cuando se serializa es mayor que el tamaño máximo de solicitud que ha configurado con la configuración max.request.size

Kafka: API de consumidor vs API de Streams

¿Cómo conectar Kafka con Elasticsearch?

INFORMACIÓN Conexión de socket cerrada para el cliente /127.0.0.1:48452 que tenía sessionid 0x15698f5ac360001 (org.Apache.zookeeper.server.NIOServerCnxn)

Kafka Streams con Spring Boot

No serviceName definido en JAAS o Kafka config (no Kerberos)

Kafka Excepción de secuencia: GroupAuthorizationException

Kafka: ¿Cómo conectar kafka-console-consumer para obtener contenido de tema de intermediario remoto?

Kafka consumidor "no pudo encontrar el líder" al buscar metadatos del tema

¿Cuándo sucede Kafka Elección de Líder?

¿Kafka admite mensajes de respuesta de solicitud

¿Cómo crear temas en Apache kafka?

Entendiendo los temas y las particiones de Kafka

Cómo escribir un archivo en Kafka Productor

¿Cómo obtener el último desplazamiento para una partición para un tema kafka?

Temas, particiones y llaves

Spring Boot Kafka: no se puede iniciar el consumidor debido a NoSuchBeanDefinitionException

Kafka arroja Java.nio.channels.ClosedChannelException

Kafka - diferencia entre desplazamiento de fin de registro (LEO) frente a High Watermark (HW)

Primavera Kafka Reintento del consumidor

org.Apache.kafka.common.KafkaException: Error al construir kafka consumidor

¿Cómo obtener el reconocimiento de Kafka broker si el mensaje es producido por el productor?

Kafka Dependencias de Maven

¿Por qué un consumidor Kafka) tarda tanto en comenzar a consumir?

Kafka excepción del consumidor y confirmaciones de compensación

Error al serializar el mensaje al enviar a kafka topic

¿Tiene kafka alguna interfaz web predeterminada?

cómo configurar kafka concurrencia del consumidor usando el arranque de primavera

¿Cómo elegir el no de particiones para un tema kafka?

Cómo consumir desde TopicPartitionOffset específico con Confluent.Kafka en .Net

Spring Kafka Error de prueba de integración al escribir en un archivo de marca de agua alta

¿Cuándo usar ConcurrentKafkaListenerContainerFactory?

Kafka Msg VS REST Llamadas

Lista Kafka Temas a través de Spring-Kafka

Cómo arreglar kafka.common.errors.TimeoutException: ha expirado 1 registro (s) xxx ms desde la creación del lote más el tiempo restante

Cómo verificar mediante programación si Kafka Broker está funcionando en Python

Cómo enviar mensajes clave y de valor con el kafka productor de consola

¿Cómo configurar Spring Kafka prueba usando EmbeddedKafkaRule / EmbeddedKafka para corregir el error intermitente de TopicExistsException?

Kafka Productor - org.Apache.kafka.common.serialization.StringSerializer no se pudo encontrar

¿Cómo usar from_json con Kafka connect 0.10 y Spark Structured Streaming?

Error al publicar mensaje en Kafka tema

Límite Kafka tamaño de lotes cuando se usa Spark Streaming

Kafka - Este servidor no es el líder para esa partición de tema

Manejo de mensajes incorrectos con la API de Streams de Kafka

¿Cómo enviar el resultado final de la agregación de flujos de kafka de una KTable con ventana de tiempo?

Kafka Connect Distributed mode El coordinador de grupo no está disponible

Kafka ¿Concurrencia de transmisión?

Kafka Connect quedando sin espacio de almacenamiento dinámico)

"Se proporcionó la configuración foo.bar pero no es una configuración conocida"

UnsatisfiedLinkError: /tmp/snappy-1.1.4-libsnappyjava.so Error al cargar la biblioteca compartida ld-linux-x86-64.so.2: No existe tal archivo o directorio

Diferencia entre KTable y tienda local

Cómo guardar el último desplazamiento que Spark consumido en ZK o Kafka y puede volver a leer después de reiniciar

Imprimir Kafka ¿Transmitir entrada a la consola?

Diferencia entre Apache Samza y Apache Kafka Streams (foco en paralelismo y comunicación)

¿Cómo comprometerse manualmente con Kafka Stream?

¿Cuál es una manera simple y efectiva de depurar conectores personalizados Kafka)?

max.poll.intervals.ms establecido en int.Max de forma predeterminada

Kafka Streams: use el mismo `application.id` para consumir de múltiples temas

Kafka Connect - Cómo borrar un conector

¿Cómo enviar un mensaje a una partición particular en Kafka?

Error al eliminar el directorio de estado en IDE para Kafka Aplicación Stream)

Valor ideal para Kafka ¿Conectar tareas de configuración de configuración de tareas distribuidas?

¿Es posible acceder a los encabezados de mensajes con Kafka Streams?

Implementar Kafka Procesador de secuencias en .Net?

Kafka Streams - Enviar sobre diferentes temas dependiendo de los datos de Streams

¿Cómo unir múltiples Kafka temas?

Utilice Kafka Streams para datos de ventanas y procesar cada ventana a la vez

Comprensión kafka grupo de flujo Por y ventana

¿Es Kafka soporte Java 10 o Java 11?

¿Cómo conectar Apache Kafka con Amazon S3?

Kafka Productor TimeOutException

Kafka Stream Suppress session-windowed-agregación

Kafka INVALID_FETCH_SESSION_EPOCH

Alternativa a openjdk: 8-Alpine para Kafka Streams

Reiniciar kafka conectar los conectores de fuente y sumidero para leer desde el principio

Kafka connect: se proporcionó la configuración XXX pero no es una configuración conocida en AdminClientConfig

¿Por qué kafka no está creando un tema? Bootstrap-server no es una opción reconocida

Kafka Connect - Error al vaciar, se agotó el tiempo de espera mientras el productor borraba los mensajes pendientes

Kafka: Use un grupo de consumidores común para acceder a múltiples temas

Diferencia entre idempotencia y exactamente una vez en Kafka Stream

Kafka Conéctese con Amazon MSK

¿Cómo gestionar Kafka KStream para unirse a la ventana de Kstream?

Prueba Kafka Topología de secuencias

RecordTooLargeException en Kafka se unen las secuencias

¿Cómo implementar Kafka aplicaciones de transmisión en Kubernetes?

Kafka Conectar fuera de Java espacio de almacenamiento dinámico después de habilitar SSL

Kafka Streams - falta el tema fuente

Cómo conectarse a una base de datos Oracle externa en Docker

Error de Serde en Kafka Proceso de transmisión con Spring Cloud Stream

Kafka Aplicación Streams Reequilibrio sin fin

Spring Cloud Stream Kafka Streams: el número de mensajes posteriores no coincide con la suma de mensajes enviados al tema

Error al crear Kafka tema: - factor de replicación mayor que los corredores disponibles

¿Se requiere una clave como parte del envío de mensajes a Kafka?

Kafka - Implementación de cola retrasada usando consumidor de alto nivel

Kafka cómo leer del tema __consumer_offsets

¿Pueden varios consumidores de Kafka leer el mismo mensaje desde la partición?