Confluent Inc.是一家总部位于Palo Alto的软件公司，由在LinkedIn上建立Apache Kafka的团队创建，该公司扩展了Kafka，每天容纳超过1万亿条消息。 Confluent构建了一个基于Apache Kafka的事件流平台，使公司能够轻松地以实时流的形式访问数据。他们的产品范围从完全自我管理的实例到Confluent Cloud。
我在KSQL中创建表或流时遇到问题。我已经做了一切，如官方示例所示，我不明白为什么我的代码不起作用。来自https：//docs.confluent.io / ...]的示例
我正在使用Confluent Kafka客户端，使用Avro架构从C＃应用程序动态向Kafka集群生成消息。数据类型在编译时未知，因此我正在使用...
如何在Docker环境中访问Kafka连接器（融合日志连接）
我目前正在基于confluent的cp-demo项目与kafka合作。 （https://github.com/confluentinc/cp-demo）我正在开发一个自定义连接器，可以在连接泊坞窗中发布它，...
从debezium mongodb连接器收到的奇数kafka消息
i使用标题连接器，通常可以按照官方手册中的描述接收创建/更新/删除消息。但我收到这样的消息：{“ _id”：“ 8762506_911”，“ $ v”：1，“ $ set”：{“ users_count”：...
Kafka Connector HDFS Sink 5.3.1无法生成所有JSON记录
用例，我从一个已经创建的Kafka主题中读取，在该主题上一个单独的集群正在生成一些键和值。我的最终目标是以JSON格式写入HDFS，对此我一直......>
我试图深入了解S3连接器的flush.size和rotation.interval.ms配置。我部署了S3连接器，似乎文件大小从6 kb一直到30 mb ...
使用Kafka Connect GCP BigQuery接收器连接器进行表分区
[伙计，我在BigQuery中使用汇流连接器进行数据传输。对于每个事件，我都创建了一个Avro模式，该模式将在BigQuery中进行解释。是否可以定义任何事件...
hi我试图深入了解s3连接器的flush.size和rotation.interval.ms配置。我部署了s3连接器，文件大小似乎从6 kb一直到30 mb ...
我们安装了docker confluent控制中心，如下所示：$ docker run -d \ --name = control-center \ --net = confluent \ --ulimit nofile = 16384：16384 \ -p 9021：9021 \ -v / tmp / control -...
我的问题很简单，但很复杂，在我目前的公司中，我们正在评估将卡夫卡与汇合使用或将卡夫卡与cloudera一起使用。我发现了您所在的融合版本的主题...
我正在生成json消息，并尝试使其符合Avro标准。这是我要发送的消息的示例，但是我收到以下错误，我认为这是由于架构不匹配...
将REST代理连接到Confluent Cloud，尝试连接到Zookeeper
我正在尝试将kafka rest代理连接到融合云。 kafka-rest-start ccloud-kafka-rest.properties这是我的属性为ccloud-kafka-rest.properties client.ssl.endpoint ....
无法在Confluent cloud basic中创建多个服务帐户
[开始使用Confluent的云产品，并创建了一个集群。能够成功创建我的第一个服务帐户，但现在不允许我创建另一个服务帐户。尝试注销，...
我可以使用融合的S3SinkConnector在s3中创建自己的目录吗？我知道它创建了一个文件夹结构，很遗憾，我们需要一个新的目录结构。
我正在尝试安装cp-helm-charts。我希望能够从外部访问拓扑。所以我做了：helm install --set external.enabled = true confluentinc / cp-helm-charts但是kubectl得到...
KEYSTORE.JKS存在失败-退出，代码1＃662-融合卡夫卡
我正在尝试将ssl配置为融合的kafka docker平台，并在开始说日志时出错：命令[/ usr / local / bin / dub path /etc/kafka/secrets/kafka.server.keystore.jks存在]。 ..
有没有办法将融合式架构注册表与kafka-node模块一起使用？
我已经在node.js中实现了Avro模式，该模式与消息有效负载一起发送。而且工作正常。我正在寻找是否可以将架构注册表与Kafka-node模块一起使用。我...
我有一个这样的Dockerfile：来自高山：3.7 COPY confluent-5.3.0 confluent-5.3.0 COPY startup.sh startup.sh COPY start-connector.sh start-connector.sh RUN chmod + x startup.sh RUN chmod + x start -...
在具有已定义配额的Kafka群集中，为了控制客户端使用的代理资源，代理计算要使违规客户端达到其配额之下所需的延迟量，并且...