英文: Stream from MSK to RDS PostgreSQL with MSK Connector 问题 我一直在这个问题上纠结了几天了。我使用kafkajs将数据发送到Kafka。每次...
62评论apache-kafka
jdbc
从MSK流式传输到RDS PostgreSQL使用MSK连接器
62评论apache-kafka
jdbc
62评论apache-kafka
jdbc
Kafka Streams – 生产异常处理程序实现的单元测试
英文: Kafka Streams - Unit test for ProductionExceptionHandler implementation 问题 I am developing a Kaf...
79评论apache-kafka
unit-testing
从SvelteKit访问Kubernetes中的Kafka
英文: Accessing Kafka in Kubernetes from SvelteKit 问题 我正在构建一个具有Kafka支持的SvelteKit应用程序。我已经创建了一个kafka.js文...
66评论apache-kafka
kubernetes
使用Debezium在SQLServer数据库中加密字段时出现NPE错误。
英文: NPE when encrypting fields for SQLServer databases using debezium 问题 我正在使用debezium将SQLServer的变更数...
52评论apache-kafka
apache-kafka-connect
消费者组在Kafka中的需求是什么？
英文: What is the need of consumer group in kafka? 问题 我不理解Kafka中消费者组的实际用途。在消费者组中，一个分区只能被一个消费者读取，因此一个主题...
48评论apache-kafka
kafka-consumer-api
Testcontainers SchemaRegistry 无法连接到 Kafka 容器。
英文: Testcontainers SchemaRegistry can't connect to Kafka container 问题 I want to run integration ...
88评论apache-kafka
java
kcat 无法连接到代理。
英文: kcat fials to connect to broker 问题 I've been trying to consume messages from broker using kcat, ...
53评论apache-kafka
kcat
在Quarkus REST API中，在@requestbody OpenAPI标签中指定多个”implementation=”标签。
英文: Specifying multiple "implementation=" tags in @requestbody openapi tag in quarkus REST...
58评论apache-kafka
rest
延迟消息消费的开始
英文: Delay the start of message consumption 问题 我有一个非常简单的Reactor Kafka消费者。 然而，为了正确处理消息，必须先执行一些@Postcon...
68评论apache-kafka
java
使用ksql从一个主题创建一张带有where子句的表格。
英文: Create a table from a topic using a where clause using ksql 问题 I'm using the latest version of K...
47评论apache-kafka
ksqldb
41