Confluent Inc.是一家总部位于Palo Alto的软件公司，由在LinkedIn上建立Apache Kafka的团队创建，该公司扩展了Kafka，每天容纳超过1万亿条消息。 Confluent构建了一个基于Apache Kafka的事件流平台，使公司能够轻松地以实时流的形式访问数据。他们的产品范围从完全自我管理的实例到Confluent Cloud。
我的接收器属性：{“名称”：“ jdbc-oracle”，“ config”：{“ connector.class”：“ io.confluent.connect.jdbc.JdbcSinkConnector”，“ tasks.max”：“ 1”， “ topics”：“ orders”，“ connection.url”：...
为什么记录不能使用Kafka Connect中的JDBC Sink连接器删除
我的接收器属性：{“名称”：“ jdbc-oracle”，“ config”：{“ connector.class”：“ io.confluent.connect.jdbc.JdbcSinkConnector”，“ tasks.max”：“ 1”， “ topics”：“ orders”，“ connection.url”：...
带有Kafka Connect的REST API源连接器-是否支持HTTPs调用？
我正在尝试使用https://github.com/llofberg/kafka-connect-rest上的社区贡献的连接器来轮询来自HTTPs REST端点的数据。我的连接器的配置为。下面：...
无法使用融合的CLI设置CLASSPATH：java.sql.SQLException：找不到适用于jdbc：oracle：thin的合适驱动程序
我想在合流上使用JDBC连接器。当我开始连接Confluent CLI时，它不起作用。汇合的本地启动连接，它给出此错误：原因：java.sql.SQLException：否...
无法使用融合的CLI设置CLASSPATH：java.sql.SQLException：找不到适用于jdbc：oracle：thin的合适驱动程序
我想在合流上使用JDBC连接器。当我开始连接Confluent CLI时，它不起作用。汇合的本地启动连接，它给出此错误：原因：java.sql.SQLException：否...
带有Spring Cloud Stream的Kafka Streams进程中的Serd错误
我正在尝试使用Spring Cloud Stream 3.0.3.RELEASE处理一些Kafka记录，但是当记录进入流管道时，Serdes配置遇到错误时遇到了麻烦。 ...
在debezium sql服务器源连接器中是否有将键字段值转换为小写的方法？
我想将SQL-Server列名转换为小写，同时将其存储在Kafka主题中。我正在使用debezium作为我的源连接器
我在本地计算机上设置了一个单节点Kafka Docker容器，如Confluent文档中所述（步骤2-3）。另外，我还公开了Zookeeper的端口2181和Kafka的端口...
全局状态存储与普通状态存储有何不同？全局状态存储是否在不同计算机上运行的所有实例中都有数据副本？由于全局状态...
我想查看主题级别的属性，例如“ message.timestamp.type”：“ LogAppendTime”，“ cleanup.policy”：“ compact”，是否可以查看在主题级别设置的所有属性？有...
[当我启动Confluent平台时，出现错误[ERROR]无法加载配置：无法解析配置文件：/home/user/.confluent/config.json：JSON输入意外结束。路径中没有文件...
Kafka-ES-Sink：ConnectException：键用作文档ID，不能为null
我正在尝试使用SMT功能添加密钥，以将其用作ES文档的文档ID，但是它不起作用。我正在使用融合ES连接器。下面的配置文件：connect-standalone.properties ...
如何从Kafka S3接收器连接器使用FieldPartitioner创建分区
我正在使用partition.class FieldPartitioner寻找适用于Kafka S3 Sink连接器的s3-sink.properties的正确格式。我需要创建3个分区（...的一个子分区……）>>
我使用查询“使用（kafka-topic =“ myTopic”，format =“ avro”创建流base_stream来创建流。）此主题的数据量超过800GB，并且还在不断增长。问题：Kafka是否重复...
[Kafka Avro使用架构注册表失败序列化/反序列化为具体类型
我似乎无法在其具体的avro实现中使用消息，但出现以下异常：org.apache.avro.generic.GenericData $ Record类无法转换为my.package类。 >
在Windows 10的Docker Ubuntu容器内安装Confluent平台
我正在尝试在Windows计算机上安装Confluent Platform。据我所知，安装Confluent Platform将使我能够访问Apache Kafka软件包中没有的KSQL。另一个...
Apache Kafka在Kafka 2.4发行版中引入了Mirrormaker2（MM2）。 MM2明显优于MM1。我知道从体系结构的角度来看，MM1曾经使用生产者和...
我是kafka领域的新手。我在RHEL7计算机（主机名：kafka-confluent）中都安装了kafka，zookeeper和架构注册表，它不是集群安装程序，所以只有1个代理。现在我...
[我正在使用Kafka connect将文件下沉到HDFS，Kafka connect具有TopicPartitionWriter，它会按时对所有分区进行翻转，并且没有基于大小的翻转。我想做基于大小的...
我想将模式注册表docker（confluent拥有的图像）与我在本地PC上安装的开源Kafka一起使用。我正在使用以下命令来运行映像：docker run -p 8081：...