it-swarm-es.com

apache-kafka

¿Kafka python API admite el procesamiento de flujo?

Kafka Consumer - Comportamiento de la encuesta

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

Kafka productor TimeoutException: Caducan 1 registro (s)

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: ¿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

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)

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

Kafka: API de consumidor vs API de Streams

¿Cómo conectar Kafka con Elasticsearch?

Kafka Streams con Spring Boot

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

Kafka Excepción de secuencia: GroupAuthorizationException

Cómo escribir un archivo en Kafka Productor

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

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

Kafka Dependencias de Maven

¿Kafka admite mensajes de respuesta de solicitud

¿Cómo crear temas en Apache kafka?

Kafka arroja Java.nio.channels.ClosedChannelException

Temas, particiones y llaves

Entendiendo los temas y las particiones de Kafka

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

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

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

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

Error al serializar el mensaje al enviar a kafka topic

Primavera Kafka Reintento del consumidor

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

¿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?

Lista Kafka Temas a través de Spring-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?

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

Kafka Msg VS REST Llamadas

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

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

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?

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

Error al publicar mensaje en Kafka tema

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

Imprimir Kafka ¿Transmitir entrada a la consola?

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

Kafka ¿Concurrencia de transmisión?

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

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

Prueba Kafka Topología de secuencias

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

Kafka Connect quedando sin espacio de almacenamiento dinámico)

Manejo de mensajes incorrectos con la API de Streams de Kafka

¿Cómo comprometerse manualmente con Kafka Stream?

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

RecordTooLargeException en Kafka se unen las secuencias

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

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

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

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

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

Implementar Kafka Procesador de secuencias en .Net?

Kafka Connect - Cómo borrar un conector

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

¿Cómo unir múltiples Kafka temas?

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

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

¿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)

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?

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

Diferencia entre KTable y tienda local

¿Cómo conectar Apache Kafka con Amazon S3?

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

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

Kafka Streams - falta el tema fuente

Diferencia entre idempotencia y exactamente una vez en Kafka Stream

Kafka Conéctese con Amazon MSK

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

Cómo crear un tema mediante programación en Apache Kafka usando Python

¿Cómo funciona el reequilibrio del consumidor en Kafka?

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

¿Cómo leer datos usando Kafka API del consumidor desde el principio?

Kafka Algoritmo de reequilibrio del consumidor