Apache Kafka是一个分布式流媒体平台，用于存储和处理高吞吐量数据流。
我一直在使用下面的CMD从打开纯文本端口的Kafka队列中获取最新的偏移量 kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 服务器：9092 --topic
Kafka connect 仅从 7 个表的列表中创建三个主题
我有kafka connect的这个配置 名称=jdbc-source-connector-oracle-1 Connector.class=io.confluence.connect.jdbc.JdbcSourceConnector 任务.max=3 connection.url=jdbc:oracle:thin:@o22.opsdb-...
SparkConf SparkConf = new SparkConf().setAppName("JavaDirectKafkaWordCount"); JavaStreamingContext jssc = new JavaStreamingContext(sparkConf, Durations.seconds(2)); 设置
无法使用 mongodb 的 Debezium 连接器从 mongodb 读取更改流
我在 mongo 数据库上进行任何更新时都会收到以下错误 { "时间戳" : "13-11-2024 T 11:41:12.255Z", “级别”：“错误”， “线程”：“
我正在尝试在 Spring Boot 应用程序中设置 Kafka 生产者以将消息发送到特定主题。我收到 SerializationException。我已经检查了我的序列化器和消息的架构...
Salesforce CRM 和 Kafka（Confluence Cloud）集成
Salesforce CRM 需要使用 Kafka 事件。 我正在评估两个选项， a) 通过 Confluence Salesforce Connector 集成 b) 通过 Mulesoft 集成。 Mulesoft 甚至会消耗 Kafka...
融合 Kafka 与 OAUTH 2 grant_type=client_credential
即使我提供了错误的 clientId clientSecret 范围 clientId =“1test_kafka”\ clientSecret =“xxx”\ 范围=“1test_kafka_access”\ unsecuredLoginStringClaim_sub=&
无法连接到 docker 镜像端口 MacOS（kafka/kafdrop 等）
我正在构建三个图像 kafka/kafdrop/elastic，每个图像都暴露于不同的端口。例如，kafdrop 66012c0676bf 黑曜石动力学/kafdrop:3.23.0“/kafdrop.sh”...
我使用 Kafka 和 Raft 模式，有 3 个代理和 3 个控制器。虽然我的 fastapi 服务运行没有任何问题，但我的 Nodejs 服务却让我头疼。在服务开始时，f...
我有以下 Flume 代理配置来从 kafka 源读取消息并将其写回 HDFS 接收器 tier1.sources = 源1 第 1 层.channels = 通道 1 tier1.sinks = 水槽1 1 级。
Kafka Streams 从 JSONObject 创建空模式
我正在编写一个 Kafka Streams 应用程序，该应用程序将从非关系自定义 Kafka 源连接器接收的数据进行转换，并将其拆分为多个主题以对其进行规范化（以便可以使用...
Quarkus 应用程序中适用于 Java 的 kSqlDB 客户端存在问题 - BatchedQueryResult 挂在 completableFuture get() 上
这是我的Java代码 导入 io.confluence.ksql.api.client.BatchedQueryResult; 导入 io.confluence.ksql.api.client.Client; 导入 io.confluence.ksql.api.client.ClientOptions; 导入 io.confluence.ksql...
我希望在一个系统中实现事务发件箱模式，该系统使用数据库表作为事务发件箱，与 Kafka 配合，以保证我的消息的一次性传送...
我想用nifi消费kafka消息，我只找到了这个组件： 是否有另一个卡夫卡处理器的安装，在文档中我找到了另一个： 就像消费KafkaRecord_2_6 有没有
确定 confluenceinc/cp-kafka:6.2.2 镜像中使用的实际 Kafka 版本
我想确定 confluenceinc/cp-kafka:6.2.2 图像中 Kafka 的确切版本。在此站点上，https://docs.confluence.io/platform/current/installation/versions-interoperability.html#cp-and-...
使用 Strimzi 与 KafkaConnect 中的 Azure 事件中心关联的架构注册表问题
我正在尝试以 Avro 格式序列化发送到 Azure 事件中心的有效负载值。我正在使用 Strimzi 将 KafkaConnect 部署到 Kubernetes，并使用 Event Hub 作为代理来代替本机 Ka...
Kafka Streams 状态存储与 MongoDB 的状态管理
我正在开发一个使用 Kafka Streams 进行组件之间通信的分布式系统。 其中一个组件（为了简单起见，BRAIN）管理发送给其他组件的一系列消息（A，...
当我们的kafka主题中有多个分区时，分区重新平衡是常见的事情吗？ 这并不一定意味着我们的应用程序存在一些延迟或问题？ 我一直在看日志...
当两个实体的事件跨越两个单独的分区时，处理 Kafka 中的实体合并吗？
使用 Kafka，我们将与实体（即客户）相关的所有事件推送到单个分区。这非常有用，因为它保留了该实体的顺序，并为我们提供了可扩展性。 茶...
我们只想为架构注册表配置代理。这意味着代理连接不能使用代理。 我正在尝试遵循架构注册表添加的配置选项...