Confluent Inc.是一家总部位于Palo Alto的软件公司，由在LinkedIn上建立Apache Kafka的团队创建，该公司扩展了Kafka，每天容纳超过1万亿条消息。 Confluent构建了一个基于Apache Kafka的事件流平台，使公司能够轻松地以实时流的形式访问数据。他们的产品范围从完全自我管理的实例到Confluent Cloud。
kafka-connect-hdfs连接器支持使用FlatBuffer模式保存字节数组和字段分区
我正在寻找kafka-connect-hdfs连接器（Confluent）支持使用FlatBuffer架构保存字节数组和字段分区。我从kafka收到字节数组中的数据。这个字节数组......
如何启用Kafka接收器连接器以便在接收器启动时将主题中的数据插入到表中
我为我的数据存储（Amppol AD S）开发了kafka-sink-connector（使用confluent-oss-3.2.0-2.11，连接框架），它将来自kafka主题的数据存储到我商店中的相应表中。 ...
我正在使用Confluent Platform学习kafka。我跟随他们的快速入门指南与docker。但是，当我尝试为该主题生成模拟数据时，我无法在其指南中找到连接器。 ...
我正在尝试使用3个zookeeper和3个kafka节点部署docker kafka集群。 kafka节点不断打印出以下错误：[main-SendThread（zookeeper-1：2181）] INFO org.apache ....
kafka-connect-jdbc：SQLException：仅在使用分布式模式时没有合适的驱动程序
我们已经使用jdbc独立连接器成功使用了mySQL-kafka数据，但现在在分布式模式下使用相同的问题（如kafka连接服务）。连接分布式....
保存的消息Kafka主题无法通过Kafka Connector正确保存
所以我设置了Confluent Kafka JDBC连接器。首先，我启动一个模式注册表，如./bin/schema-registry-start ./etc/schema-registry/schema-registry.properties这是模式-...
我正在尝试使用Confluent Kafka REST代理从我的一个主题中检索Avro格式的数据，但不幸的是我收到了反序列化错误。我正在使用...查询Kafka REST代理
有没有办法使用Kafka Confluent REST API生成带标头的Kafka消息？
我正在尝试使用一些自定义标头向Kafka发送消息，但我找不到办法。根据该文档，POST / topics /（string：topic_name）API无法附加...
我正在使用Kafka版本0.11.0.0并尝试通过从avro文件加载数据来创建输入流。但它在实例化生产者时失败，例外：[main] INFO org.apache.kafka ....
我使用基本的Kafka-Logstash设置来与后端同步许多不同的应用程序。我对这是如何工作有一个非常基本的了解。目前我正在研究分析数据......
我使用以下命令在Windows中运行Kafka和Zookeeper：zookeeper-server-start.bat config / zookeeper.properties kafka-server-start.bat config / server.properties。 1.我如何运行架构......
Kafka Connect JDBC：它是否可以在批量模式下加载banle，但仅当表中的任何记录发生变化时？
当我需要加载维度表到kafka时，我有一个situtation。 Juts因为我希望通过kafka公开我的所有应用程序数据，这是所有公司部门/产品的常见方式。但我的维度是......
面临的挑战是创建一个Kafka生产者，该生产者连接到Kafka集群，该集群位于该集群外部的Kubernetes集群中。我们有几个RDBMS数据库，它们位于内部并且......
汇合Kafka Streams - 找不到类io.confluent.connect.avro.ConnectDefault
我正在使用带有查询模式的jdbc源连接器，似乎没有指定的表名，在schema-registry中为记录键和记录值注册的模式为空...
从JDBC Connector反序列化avro kafka消息时出错
我正在尝试使用汇合的kafka连接功能来收听我发布的主题。但是，我无法对其进行反序列化。我相信它的avro序列化但不能......
处理模式注册表deserialiser kafka时出现异常
我正在关注汇合链接，以便在更改mysql表时发布kafka消息。当我尝试从springboot应用程序中使用此消息时，我得到以下异常。我怎样才能解决这个问题 ...
从AvroConverter开始时出现Kafka Connect错误
我正试图从一个主题下沉到卡桑德拉。该主题具有由kafka流创建的avro文件的模式注册表。这是我的connect-standalone.properties：bootstrap.servers = localhost：9092 ...
我正在尝试使用Confluent InfluxDB接收器连接器将主题中的数据导入我的InfluxDB。配置如下所示：connector.class = io.confluent.influxdb.InfluxDBSinkConnector ...
如何使用Kafka connect将MS Sql Server表导入KSQL
您好我正在尝试将远程SQL Server上的所有表导入KSQL主题这是我的文件属性connector.class = io.confluent.connect.cdc.mssql.MsSqlSourceConnector name = sqlservertest tasks ....
我正在使用scala 2.12并在我的build.sbt中有以下依赖项。 libraryDependencies + =“org.apache.kafka”％“kafka-clients”％“0.10.1.0”libraryDependencies + =“io.confluent”％“kafka-avro -...