confluent-platform专题提供confluent-platform的最新资讯内容,帮你更好的了解confluent-platform。
我正在使用5.5版 我有一个源连接器,它在数据库停止时停止工作,在数据库返回时再也无法恢复。
当我在融合控制中心中下载连接器配置json文件时,无法看到创建它的人的密码,如何隐藏它? 可
“我的主题架构”如下所示, <pre><code>{ &#34;schema&#34;: { &#34;type&#34;: &#34;string&#34;, &#34;optional&#3
运行kafka流应用程序时出现以下错误。 KS应用程序加载大量(20GB)数据并将其保存在状态存储中。
我使用Debezium 1.2 我有MSSQL数据库,想将一个表中的数据发布到其他DB中的许多其他表中(Debezium的
使用apache kafka connect api和confluent kafka connect api有什么区别? 任何人都可以共享代码以将MYSql DB连接到Kafka
在我的主题的Avro模式中,有两个字符串字段,<code>field1</code>和<code>field2</code>。当前是否可以在JDBC Sink
<pre><code>temp.groupby(&#34;ParentId&#34;).agg({&#34;score&#34;:np.mean, &#34;body&#34;: lambda x: &#34; &#34;.join([I for I in x])}) </cod
说我们有一个带有2个分区的Topic,并且没有n个生产者正在为该Topic生产数据。现在,数百万的MessageRecords
我有一个基于字符串的键值对-具有大陆和国家/地区名称。大陆是关键,而国家/地区则作为值列出。我
<pre><code>OS: ubuntu 18.x Confluent Schema Registry: community edition version 5.5.1 Kafka: AWS MKS (Apache Kafka 2.2.1) </code></pre> <p
我们在Amazon EKS中托管了Confluent Connect v5.01容器集群,以运行Debezium for SQL Server连接器v0.9.5的多个实例。有
说,我有以下内容:- <ul> <li>具有20个分区的单个主题。</li> <li>我有10个单独的实例为streams-app供电(
我正在尝试使用<a href="https://hub.docker.com/u/confluentinc" rel="nofollow noreferrer">confluentinc</a>码头工人镜像在Kuber
我刚刚开始与C#(dotnet核心)一起使用Kafka。我已经使用docker(Confluent Images)通过Schema Registry完善了Kafk
我在Docker Wsl2上运行Kafka,主题为test02,并尝试将该主题沉入Mysql数据库中。 我已经配置了用户和用户特
我正在尝试从neo4j流向kafka主题发送消息。 这是我的neo4j的docker-compose配置 <pre><code>version: &#39;3&#3
如果我尝试传输GenericRecord类型的avro记录,为什么我的代码执行会在KafkaProducer.send()上阻塞? 如果我
我对卡夫卡的<a href="https://docs.confluent.io/current/kafka/tiered-storage.html" rel="nofollow noreferrer">tiered storage feature<
im使用融合的sftp连接器从远程sftp服务器流传输数据 这是连接器的.properties文件: <pre><code>name=SftpSourc