英文: How to start a dockerized Kafka instance and connect to it from the host machine? 问题 以下是翻译的部分: 如...
Trying to start kafka , Schema registry in docker containers using Testcontainers
英文: Trying to start kafka , Schema registry in docker containers using Testcontainers 问题 我正在尝试在 Dock...
只能获取Debezium中的创建和更新过程吗?
英文: How can I get only the create and update processes through Debezium? 问题 I'm capturing changes wi...
我可以在由Kafka Connect从CSV文件创建的所有消息中添加任意键吗?
英文: Can I add arbitrary key to all messages created by Kafka Connect from a csv file? 问题 我需要将由Kafka ...
Kafka消息消费期间的最佳灾难容忍方式
英文: Optimal way of disaster tolerance during Kafka message consumption 问题 我目前有一个用于消费Kafka主题消息的服务,进行一...
我们可以直接在Spring Kafka中使用Protobuf吗?
英文: Can we directly use the protobuf in spring-kafka? 问题 我想创建一个使用Kafka的Spring Boot应用程序,其中生产者和消费者都只使用...
MSK(Kafka)IAM身份验证和Terraform
英文: MSK (Kafka) IAM Authentication and Terraform 问题 我正在尝试在MSK集群上进行Kafka主题的Terraform配置。 要求是设置为IAM访问控制...
如何创建 ksql_processing_log 并将错误发送到 Kafka 主题。
英文: How to make ksql_processing_log and send error to kafka topic 问题 I update log4j.properties in ks...
Is it possible to create a service that consume both message streaming (from Kafka) and also read REST API request, in Go?
英文: Is it possible to create a service that consume both message streaming (from Kafka) and also rea...
Kafka Sink Connector的滞后一直显示为1,即使在处理所有记录后。
英文: Kafka Sink Connector lags always show 1 even after processing all records 问题 I am new to Kafka c...
41