我一直试图将数据从SAP HANA加载到HDFS，并且我使用“ AEDAT”作为增量列。 日期格式“ AEDAT”具有“ YYYYMM

我正在尝试使用复制器<a href="https://docs.confluent.io/current/schema-registry/installation/migrate.html" rel="nofollow norefer

我正在使用kafka连接从Oracle db到Kafka主题的源数据。我想基于增加的id或status列从一个表中获取数据，例

我试图在任意时间窗口内获取ksqlDB表中的事件计数。<br/> 表<code>my_table</code>是用<code>WINDOW SESSION</code>创

<img src="https://i.stack.imgur.com/x2Fxh.png" alt="The output on consumer console screenshot"/> 应用程序（.java）文件

我将开始在两个不同的DC中部署几个Kafka集群以生产。我的主要用途是使用MirrorMaker复制。为了在DC之间连

速率限制：由于Kafka能够以比MQ可以消耗的速率高得多的速率生成消息，因此我们可以在kafka使用者上进

我的应用程序控制台日志显示很多以下内容： <pre><code>jmp</code></pre> 这些都不出现在应用程序日志

所以我正在学习有关Kafka的信息，只是试图在帮助下在本地环境中进行设置 泊坞窗组成文件。我正在从

这是与<code>Confluent.Kafka</code>的{​​{1}}依赖性相关的控制台日志的摘录。 <pre><code>librdkafka.redist</code><

我正在使用挂钟时间，并且想要将传递给标点符号的<code>punctuate</code>方法的时间戳与存储在记录字段中

我想从KSQLDB 5.5.1中的结构选择数组中转换主题 问题：没有struct函数的数组 例如： 数据-> 身份

用例是从2个输入Avro主题中读取，然后生成1个输出Avro主题。该主题有3个分区，复制因子1，保留期为7天

Google并没有帮助我，所以我想问你。我有很多关于Kafka的话题，我看过很多关于Java堆内存的文章，等等

我正在使用Debezium和kafka connect。我需要从下面的有效负载中提取“ listid”，并能够将其分配给kafka消息

早上好。 我已将复制器从一个融合群集（Pro）配置为另一个（Dev），并且正在测试该选项以避免重

我们有一个托管的Kafka设置（Confluent平台，Kafka connect 5.5.1），可通过8到10个连接器流式传输来自约40个主

下面的代码是我的Kafka-connect-JDBC和MySQL驱动程序的Dockerfile <pre><code>FROM debezium/connect:1.3 ENV KAFKA_CONNECT_J

<h2>设置Kafka连接器管道时出错</h2> <h3>环境概述：</h3> Docker容器 <ol> <li> docker run --name some-mysql -e MYSQL_R

我有两个要加载到我的架构注册表中的avsc文件，<code>Message</code>和<code>MessagePart</code>。 <code>Message</code>