Confluent Inc.是一家总部位于Palo Alto的软件公司，由在LinkedIn上建立Apache Kafka的团队创建，该公司扩展了Kafka，每天容纳超过1万亿条消息。 Confluent构建了一个基于Apache Kafka的事件流平台，使公司能够轻松地以实时流的形式访问数据。他们的产品范围从完全自我管理的实例到Confluent Cloud。
我正在尝试将嵌套的数组对象插入KSQL表。我的表结构如下：CREATE TABLE nlpArticlesTrain（“ articleText” VARCHAR，“ ner” ARRAY ]
我有几个无法连接到Kafka Cluster的使用者。同时，我想了解这些使用者的配置方式。是否有API可用于...
我是kafka的初学者，已经开发了kafka消息的消费者，现在看起来不错。尽管在测试消费者时有一个要求可能会有些节制...
我正在尝试使用此链接https://github.com/confluentinc/cp-helm-charts/tree/e17565cd5a6985a594155b12b08068cb5882e51f/charts/cp-kafka-connect上的融合头盔图表，但将其安装在...
我有一个无状态的Kafka Stream，它从一个主题中消费并发布到forEach中的另一个队列（Cloud PubSub）中。拓扑并没有终止于产生新的Kafka主题。我如何...
cp-schema-registry不在Kubernetes中启动
将cp-schema-registry从4.1.2升级到5.5.0后，schema-registry无法启动。首先，它失败并出现错误ZULU_OPENJDK_VERSION = 8 = 8.38.0.13 _ = / usr / bin / env ===> User uid = 0（root）gid = ...
使用Kafka REST代理发布Avro消息会引发“将JSON转换为Avro失败”
我正在尝试发布一条消息，其中包含一个字段的联合，例如{“ name”：“ somefield”，“ type”：[“ null”，{“ type”：“ array”，“ items”：{“类型”：“记录”，...
在事件驱动的项目中，我收到命令类型的消息，而在响应中，我收到事件。这些命令和事件消息表示域，因此它们包含域中的复杂类型。例如：...
我已经构建了这个docker composer文件：版本：'2'服务：zookeeper：图片：$ {REPOSITORY} / cp-zookeeper：$ {CONFLUENT_DOCKER_TAG}主机名：zookeeper container_name：zookeeper ...
如何在后台（守护程序）运行Kafka Connect connect-distributed.sh？
我通过ssh连接到远程主机，然后运行./connect-distributed ../etc/kafka/cusom-connect-distr.properties，现在无法使用终端输入。我尝试了-daemon选项，但没有成功...
我已经在docker的帮助下开始在Windows上融合平台。我能够启动Kafka Broker，Zookeeper和控制中心。我也在docker中设置了confluent-cli。现在当我...
我已经在https://docs.confluent.io/current/quickstart/ce-docker-quickstart.html的帮助下使用Docker在Windows 10上启动了Confluent Platform。现在，我想尝试使用Confluent CLI。但是我...
Confluent HttpSinkConnector给出的错误是当复制因子在任何地方都被称为1时，复制因子为3
我正在使用Confluent HttpSinkConnector并按照本页中提到的步骤进行操作：https://docs.confluent.io/current/connect/kafka-connect-http/index.html我已经更新了连接器接收器...
我如何为Confluent Schema Registry指定nodePort？
参考下面的掌舵图：https://github.com/confluentinc/cp-helm-charts我试图使架构注册表可用于k8s集群中的pod。为此，我添加了一个...
我有以下格式的数据进入卡夫卡。 {“ WHS”：[{“ Character Set”：“ UTF-8”，“ action”：“ Finished”，“ Update-Date-Time”：“ 2020-04-11 09：00：02：25”，“数字“：0，” Abbr“：”“，”名称“：”“，” Name2“：”“，”国家-...
我无法从外部连接到我的kafka群集。侦听器和公告的侦听器似乎存在问题。有什么建议么？当我尝试从外部在端口30092上进行连接时，...
我的汇合接收器属性：name = sink-oracle connector.class = io.confluent.connect.jdbc.JdbcSinkConnector task.max = 1＃要使用的主题-像这样的接收器连接器所必需的...
我的接收器属性：{“名称”：“ jdbc-oracle”，“ config”：{“ connector.class”：“ io.confluent.connect.jdbc.JdbcSinkConnector”，“ tasks.max”：“ 1”， “ topics”：“ orders”，“ connection.url”：...