-
如何使用Kafka数据源指定流查询的Kafka自定义配置(例如Confluent Cloud身份验证)?
我想使用针对Confluent Cloud的结构化流进行读写。问题是我无法在文档中找到进行身份验证的方法。 < -
群集中3台Linux不同计算机上的Confluent Platform Docker群集
我们正在搜索说明如何通过docker在3个不同的Linux计算机上以群集方式安装Confluent平台的文档 我们 -
合计架构注册表UnknownTopicOrPartitionException:此服务器未托管此主题分区。
全新服务器,全新安装的confluent-community-2.12版本5.3.1。 架构注册表配置有<code>/etc/schema-registry/schema -
融合的Kafka Connect Docker映像运行状况开始
我一直遵循本指南<a href="https://docs.confluent.io/current/quickstart/ce-docker-quickstart.html" rel="nofollow noreferrer">https: -
kafka主题中所需的分区数,以在KSQL中创建流
尝试从现有的Kafka主题在KSQL中创建Stream时,我面临以下错误。 <blockquote> io.confluent.ksql.exception.K -
所需的融合复制器端到端延迟度量
<strong>问题陈述:</strong>:我正在尝试从<strong>本地到AWS </strong>数据复制来确定<strong>复制器的端到端延 -
Kafka Connect JDBC Sink连接器-java.sql.SQLException:找不到合适的驱动程序
我正在尝试在docker的帮助下使用kafka debezium(Kafka Streaming)将表数据沉入另一个DB。 DB流工作正常。但是 -
卡夫卡的IIDR CDC是否需要Confluent平台?
我已经为Kafka 11.4.0安装了IIDR CDC。使用Confluent软件包是强制性的,还是可以使用CDC直接连接到我的Kafka实例? -
使用Kafka JDBC源连接器时,每秒只能获得1000条记录。如何提高记录提取率
我正在使用带有JDBC源连接器的kafka connect。该连接器工作正常,但我每秒只能收到1000条消息。 Oracle DB中 -
如何检查Confluent Control Center中某个主题的“较旧”消息,
您能告诉我如何检查主题的“旧”消息吗(来自Confluent Control Center)? 我已登录并尝试检查,但 -
从RabbitMQ队列读取时的Kafka Connect问题
我正在尝试使用具有以下配置的Kafka连接器从RabbitMQ队列中将数据读入主题: <pre><code>{ "name" : -
使Secure Kafka和Schema注册表相互对话,以及对其进行Spring Boot配置
嘿,我已经尝试解决大约两个星期了。 基本上,我希望kafka在HTTPS的SSL和架构注册表中。不能使用任何人 -
在mqtt souce连接器上设置Kafka主题
我正在使用融合平台5.3.1,并使用以下方式在分布式模式下定义了两个不同的mqtt源连接器: <pre><code> -
为什么在kubernetes中拆分新的pod后无法重新启动架构注册表
我在kubernetes中运行schema-registry遇到麻烦,想知道是否有人可以解决以下版本不兼容错误。 Confluent的文档 -
Confluent Cloud中的邮件值无法正确解码
我对卡夫卡很陌生,并且很融合。我使用自己的虚拟模型编写了与<a href="https://www.confluent.fr/blog/schema-regi -
kafka-connect-elasticsearch:如何发送文件删除?
我有一个看起来像这样的处理流: <pre><code>mysql.database -> debezium-connector -> database topic -> faust.ag -
融合云-> BigQuery-如何诊断“不良记录”原因
我可以将数据从MSSql Server推送到Confluent Cloud上的Topics,但不能将其从主题推送到BigQuery,它会引发错误“ -
使用Kafka-ElasticSearch接收器连接器在ElasticSearch中索引Kafka主题时出现MapperParsingException错误
我正在使用elastic7.4和融合的kafka-elasticsearch水槽连接器。 1)使用以下配置在合流中创建了kana-elast -
KSQL流-从结构数组获取数据
我的JSON看起来像: <pre><code>{ "Obj1": { "a": "abc", "b": "def", " -
使用Confluent Replicator在每个分区中的订购保证
我们的系统中需要维护Kafka主题分区内记录的正确顺序和记录顺序。 正如我们在测试运行中观察到的那 -
编译Confluent KsqlDB时类型转换问题
我正在尝试使用Java 11.0.2编译(<code>mvn pacakge</code>)KSQL v5.3.1。 我在编译<code>ksql-common</code>时遇到 -
启动Kafka Connect Debezium
我在这里设置了融合平台 STEP 1 <pre><code>wget /usr/local http://packages.confluent.io/archive/5.2/confluent-5.2 -
为什么我应该将docker image“ confluentinc / kafka”用于kafka集群?
我做了 <pre><code>docker-compose up </code></pre> 在我的本地进行kafka集群。 并且每当我要创建主题 -
如何使用复合键从主题创建KSQL表?
我有一些带有字段<code>stringA</code> <code>stringB</code>的主题数据,而我只是在根据主题创建KSQL表时试图将 -
Kafka Connect JDBC接收器连接器问题
运行JDBC接收器连接器时出现以下错误 <pre><code>[2020-01-08 15:05:39,271] ERROR Plugin class loader for connector: ' -
融合的Kafka Python生产者未使用ACKS =所有配置进行生产
我有一些会生成kafka主题的python代码,在默认设置<code>acks=1</code>下可以正常工作,但是当我更改为<code>ac -
我们可以在视图或实例化视图上设置CDC跟踪吗?
我们可以在视图或实例化视图上设置CDC跟踪吗?我们正在使用融合平台,来源是SQL Server,而CDC工具是debe -
KSQL流-遍历JSON
如何在KSQL流中遍历JSON: 我的JSON看起来像: <pre><code>{ "Obj" { "ID" : "1" -
无法在macOS 10.12中导入confluent_kafka?
我遇到以下错误: <pre><code>_________________ ERROR collecting tests/test_python.py _________________ ImportError while impo -
无法发送带有嵌入到Kafka主题的架构的JSON(使用邮递员):错误代码422
我想使用邮差将json发送到Kafka主题。 在邮递员中,发送以下json时,一切正常(kafka没有返回错误