是否有适用于AWS SQS和Kafka的通用SDK？
我们正在使用AWS SQS，并希望使我们的应用程序与云无...
融合架构注册表：JDBC连接器不支持向后兼容吗？
为了了解CDC管道的模式演变，我试图将头绪围绕在以下...
在Snowflake Kafka连接器中，我们可以定义文件类型吗
在Snowflake kafka连接器中，我可以使用预定义的数据...
我的FlinkKafkaProducer011需要的参数比预期的要少
我在使用FlinkKafkaConnector时遇到困难。 尽管我已...
Flink消费者工作无法从Docker连接到Kafka
我有一个简单的Flink Scala流媒体作业，该作业连接到...
使用Prometheus监控卡夫卡滞后
我决定通过Prometheus和Grafana来监控我的卡夫卡消费...
Kafka使用者即使订阅了该主题也无法收到消息
我正在订阅一个主题并尝试使用消息，但是，尽管我看...
如何在Spring Boot中延迟加载Kafka Consumer？
我想通过命令行参数提供组ID，但尝试此操作时出现以...
Java客户端配置了单个Kafka代理IP和要连接的端口，如果该代理在集群中关闭了怎么办
我有一个Java使用方使用broker1：9092连接到kafka集...
我是否可以使用带有包含作为枚举成员值的枚举的Avro模式？
这是我要转换为Avro模式的Java枚举： <pre>&l...
获取kafka使用者中的timestamp_ms值
我正在使用kafka-python == 2.0.1 producer.py &...
spark和kafka之间的版本兼容性
我正在将Spring Boot从<code>1.5</code>...
是否有与REST API集成并将数据写入kafka主题的Kafka连接器？
我的项目中有一个要求，在该项目中，必须在单击REST...
Springboot Kafka异常javax.management.InstanceAlreadyExistsException
我的应用程序具有多个springboot服务，这些服务在ap...