我已经发布了一个问题<a href="https://stackoverflow.com/questions/63310003/when-enablesslcertificateverification-is-set-to-true-
Confluent Control Center似乎是模块化的，但是我还没有找到有关如何构建自己的插件以进行Kafka自定义管理
因此，我有一种情况想与我所订阅主题的模式相匹配。我主题的结构是3部分的“ part1.part2.part3”，例如D
我想问您一些关于apache kafka和紧凑主题的问题。我们想提供一些关于Kafka压缩主题的PII数据。我们要通过
我了解到，GetOffsetShell用于获取主题分区的偏移量。
t为-1表示最新消息，t为-2表示第一条消息。
Kafka使用者应用程序在启动停止使用者服务的过程时抛出ObjectDisposedException。我想了解是哪个进程破坏了
在AWS Fargate中使用Debezium postgresql源连接器运行confluentinc / cp-kafka-connect：5.5.1。
在第一次运行时，没
我是Confluent Schema Registry的新手，我试图首先了解核心概念。
我对<code>TopicRecordNameStrategy</code>有点模糊：
正在尝试从python向kafka消费者发送消息。但是由于<code>ERROR Unknown error when running consumer: org.apache.kafka.common
以下是<strong>指标</strong>列中的示例数据：
<pre><code>{
"data": "[{'val': '[{'TS': &
尝试使用融合文档中提供的某些参数时，Kafka rest代理失败。<br/>
如果尝试使用文档[https://docs.confluent.io/c
Am正在尝试将数据从一个流文件传输到另一文件。它运行得更早，突然提供了错误<code>ERROR Stopping due to e
Confluent.Kafka AdminClient允许您创建一个主题，指定名称，分区数，复制因子和保留时间（我猜是通过configs
我正在使用kafka kafka_2.11-0.11.0.2和融合版本3.3.0进行架构注册。
我已经定义了如下的avro模式：
<pr
我正尝试在Scala中制作kafka流。我想知道是否有可能将kafka流转换为kafka全局ktable？
如果是，怎么办？
我尝试使用Confluent BigQuerySinkConnector创建从Kafka到BigQuery数据管道。测试环境是一个<a href="https://i.stack.imgur
我尝试使用有关Kafka主题的JSON数据创建到BigQuery的数据管道。测试环境是一个cp-all-in-one docker容器。我添
是否有办法获取一天中通过Kafka主题到达的邮件数量？
寻找一种可以获取特定日期在某个主题上到达的
我想知道是否允许使用JSON密钥架构和AVRO值架构生成消息。
生产者记录的混合和匹配模式类型是否
我有一个消费者应用程序，它期望JSON像这样：<code>{"timestamp":1554138000,"level":"first","m
