Preguntas con Tag: apache-kafka
Apache Kafka es una plataforma de streaming distribuida que se utiliza para construir tuberías de datos en tiempo real y aplicaciones de streaming.
Camel Kafka S3 Fuente Connector con múltiples conectores para el mismo cubo
Estoy tratando de definir los conectores de la Fuente Camel S3. He buscado un poco sin éxito para encontrar respuestas a las siguientes preguntas.
Cómo puedo configurar mi conector de ta
amazon-s3
apache-kafka
apache-kafka-connect
apache-camel-aws
s3-kafka-connector
3 años, 4 meses, 27 días
transforma.route.topic.expresión y expresión groovy
Estoy tratando de utilizar debezium transformas.route.topic.expression
Aquí las entradas en configuración del conector
"transforms": "dropPrefix,unwrapi,route",
"transforms.dropPrefix
groovy
apache-kafka
debezium
3 años, 4 meses, 27 días
Cómo conectar kafka al servidor externo. ip
Tengo Kafka puesta en mi máquina local, y estoy usando github.com/segmentio/kafka-go implementar el modelo de productor de consumo y trabajar bien con localhost.
Pero quería conectarse
go
apache-kafka
3 años, 4 meses, 29 días
¿Exponer directamente a mis corredores Kafka a consumidores externos o utilizar una puerta de entrada basada en http?
¿Cuál es la mejor manera de exponer mi ecosistema Kafka a aplicaciones de terceros que necesitan consumir o publicar mensajes?
Use una puerta de entrada (con base en http) para ocultar l
apache-kafka
3 años, 4 meses, 27 días
¿La mejor manera de ejecutar múltiples consumidores de consola Kafka?
Escribo Kafka consumía mensajes en un archivo (backup.log). Para hacer esto, he creado un servicio en mi CentOS que funciona kafka-console-consumer.sh --bootstrap-server kafka1:9092 --topic t
apache-kafka
3 años, 4 meses, 27 días
Reactor - Kafka - El consumidor detiene el error mientras procesa el mensaje
Estoy usando Reactor-Kafka 1.2.4 y actualmente se enfrenta a la cuestión de que al encontrar un error al procesar el mensaje,
el consumidor de Kafka se detiene y no continúa procesando otros mensaj
apache-kafka
reactor-kafka
3 años, 4 meses, 28 días
Reproducción de postgres ranura mostrando inactivo
Estoy usando el conector debezium postgres para la captura de datos de cambio. Uno de los conectores está transmitiendo eventos de cambio a Kafka pero todavía la ranura está mostrando como inactivo
postgresql
apache-kafka-connect
debezium
3 años, 4 meses, 27 días
debezium 1.2 para conector postgres 10
Tengo una versión Postgres 10 e intento configurar un conector de debezium con Kafka.
A continuación se encuentra el ajuste que hice
Set Wal_level = 'logical'
cr
postgresql
apache-kafka
debezium
3 años, 4 meses, 27 días
Utilizar API transaccional y exactamente una vez con productores y consumidores regulares
Documentos confluentes que pude encontrar todo el enfoque en la aplicación Kafka Streams cuando se trata de
apache-kafka
3 años, 4 meses, 27 días
Cómo establecer el nombre de esquema dinámico en el conector fuente JDBC Kafka
Estoy usando el conector fuente SAP HANA "connector.class":"com.sap.kafka.connect.source.hana.HANASourceConnector" para importar datos en temas kafka.
Quiero tener el nombre/nomb
jdbc
apache-kafka
apache-kafka-connect
hana
3 años, 4 meses, 29 días
Error con archivo CSV decodificado: InvalidArgument Error: Los campos no citados no pueden tener citas/CRLFs dentro
Estoy usando Python 3.7.7, versión tensorflow-io: 0.17.0 y versión de tensorflow: 2.4.0. Quiero leer el archivo CSV de Kafka y utilizar esos datos para entrenar el modelo. Todo el código se puede e
python
csv
tensorflow
apache-kafka
3 años, 4 meses, 27 días
Kafka no publica cambios en los archivos
Leyendo:Kafka Connect FileStreamSource ignora las líneas adjuntas
Una respuest
apache-kafka
3 años, 4 meses, 27 días
Las rutas de Camel no se identifican, al ejecutar la aplicación, se inician 0 de 0 rutas totales
Tengo una aplicación de camello y no reconoce las rutas. Es una bota de primavera
aplicación.
Esta es la clase de aplicación de arranque de primavera
He definido todas las propiedades e
java
spring
maven
apache-kafka
apache-camel
3 años, 4 meses, 27 días
Kafka RoundRobin particionista no distribuye mensajes a todas las particiones
Estoy tratando de utilizar la clase RoundRobinPartitioner de Kafka para distribuir mensajes uniformemente a través de todas las particiones. La configuración de mi tema Kafka es la siguiente:<p
apache-kafka
kafka-producer-api
round-robin
partitioner
3 años, 4 meses, 27 días
¿Cómo consume SpringCloudStream Kafka a granel?
Kafka nativa se puede utilizar KafkaConsumer.poll () para obtener mensajes en lotes. Cómo configurarlo después de integrar el flujo de arranque de la nube de primavera Kafka (3.0.10. ¿Liberar? No e
apache-kafka
apache-kafka-streams
spring-kafka
3 años, 4 meses, 28 días
No es capaz de iniciar Kafka-Minion contenedor
No es capaz de iniciar el contenedor kafka-minion.
#
{"level":"fatal","msg":"Error parsing env vars into opts. required key KAFKA_BROKERS missing value","time":"2020-12-19T05:16
docker
apache-kafka
3 años, 4 meses, 26 días
Garantizar la coherencia con Kafka Schema y la especificación OpenAPI
Varias API/microservices proporcionan acceso a recursos críticos, incluidos los temas de Kafka. Los mensajes API/microservice se validan mediante una especificación OpenAPI que define el contrato A
apache-kafka
microservices
openapi
confluent-schema-registry
3 años, 4 meses, 29 días
¿Es posible consumir cada mensaje de un tema kafka por separado?
Ok aquí está el objetivo:
Tengo un servicio que se supone que envía correos, si esto falla, mi productor Kafka enviará este correo a un Kafka-topic. Un segundo programa mira cada dos minutos en el
java
apache-kafka
kafka-consumer-api
quarkus
3 años, 4 meses, 29 días
Failing to AVRO serialise on only one consuming microservice
Tengo cinco Kafka consumiendo servicios y un servicio de producción de Kafka. Estoy después de lanzar un nuevo esquema avro en una biblioteca de consumidores en cada uno de los microservicios que c
apache-kafka
kafka-consumer-api
avro
confluent-platform
confluent-schema-registry
3 años, 4 meses, 29 días
Acondicionado (basado en el contenido) en los encabezados de Kafka en Spring Cloud Stream
Estoy usando Spring Cloud Stream 3.x en la aplicación Spring Boot 2.x para consumir mensajes de un tema Kafka.
Quiero tener un oyente que consume mensajes condicionalmente en algún valor de e
spring
spring-boot
apache-kafka
spring-kafka
spring-cloud-stream
3 años, 4 meses, 28 días
Kafka Connect - Connector with same Kafka cluster as a source?
Sólo encontré referencias a MirrorMaker v2.
¿Puedo reutilizar? org.apache.kafka.connect.mirror.MirrorSourceConnector como si fuera un conector "plain" con Kafka como fuente, o ha
apache-kafka
apache-kafka-connect
3 años, 4 meses, 27 días
¿Por qué no puedo establecer deserializador en la fábrica de consumidores?
Todo el mundo.
package kitchen;
import entity.Order;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.common.serialization.StringDeserializer;
import
java
spring-boot
apache-kafka
spring-kafka
3 años, 4 meses, 28 días
¿Cómo interpretar el registro activo cuenta métrica de una tarea de conexión kafka?
Tengo un conector de tareas de conexión kafka (conector de postgres jdbc) y puedo ver el kafka_connect_source_task_source_record_active_count_avg métrica de este conector. Noto que el
apache-kafka
apache-kafka-connect
3 años, 4 meses, 28 días
KsqlDB Convertir de TextNode en Array
TL;DR: En ksqlDB, hay una manera de convertir un TextNode en un Array así que... EXPLODE se puede realizar sin error?
Marca nueva a k
apache-kafka
ksqldb
3 años, 4 meses, 28 días
Operaciones de Kafka [privadas]
<
apache-kafka
architecture
software-design
3 años, 4 meses, 27 días
Cómo podemos dejar el tema kafka en presto
Necesito empujar un archivo JSON en un tema de Kafka, conectando el tema en presto y estructurando los datos de JSON en una tabla de preguntas.
Estoy siguiendo este tutorial
apache-kafka
presto
kafka-producer-api
connector
3 años, 4 meses, 28 días
por qué ADD COLUMN a la mesa kafka no se admite en Clickhouse
Tengo un problema agregando una columna a la cola de Kafka en ClickHouse.
He creado una mesa con el comando
CREATE TABLE my_db.my_queue ON CLUSTER my_cluster
(
`ts` String,
apache-kafka
clickhouse
3 años, 4 meses, 28 días