confluent 相关问题

Confluent Inc.是一家总部位于Palo Alto的软件公司，由在LinkedIn上建立Apache Kafka的团队创建，该公司扩展了Kafka，每天容纳超过1万亿条消息。 Confluent构建了一个基于Apache Kafka的事件流平台，使公司能够轻松地以实时流的形式访问数据。他们的产品范围从完全自我管理的实例到Confluent Cloud。

融合KSQL中的空处理

能告诉我如何在KSQL中处理Null值吗？我试图处理4种可能的方法，但没有得到解决。尝试用4种方法在KSQL中用不同的值替换NULL但是给...

apache-kafka confluent ksql

回答 1 投票 1

汇流控制中心不拦截流

我正在使用带有Kafka流的CCC，该流由Debezium的Postgres连接器填充。我正在使用以下docker-compose.yml：version：'2'服务：zookeeper-1：image：...

postgresql apache-kafka apache-kafka-connect confluent debezium

回答 1 投票 0

如何为Kafka Connect和Spark注册和使用AVRO Schema？

我不太明白如何在jdbc源或接收器连接器中注册模式以使用它并在Spark中读取数据这是我想用来从...检索记录的avro模式

apache-spark apache-kafka apache-kafka-connect confluent confluent-schema-registry

回答 1 投票 0

Kafka AVRO Consumer：MySQL Decimal到Java Decimal

我试图从MySQL表中消耗记录，其中包含3列（Axis，Price，lastname）及其数据类型（int，decimal（14,4），varchar（50））。我插入了一条有...的记录

java mysql apache-kafka apache-kafka-connect confluent

回答 1 投票 0

Kafka汇合4.1.1重启问题 - 以前创建的主题未显示

我正在使用kafka confluent-4.1.1。我创建了一些主题并且效果很好。如果我重新开始汇合，我看不到以前创建的主题。我尝试了帖子中提到的建议：卡夫卡主题没有......

apache-kafka confluent

回答 1 投票 0

汇总：加载连接器后未创建主题

我尝试连接到几个数据库，包括MySQL和MSSQL，我没有问题。但是，当我试图连接到某个远程MySQL数据库时（可以只访问我公司的...

jdbc apache-kafka apache-kafka-connect confluent

回答 1 投票 3

卡夫卡抵消管理

我们正在使用Kafka 0.10 ......我在网上（以及文档中）看到一些有关如何在enable.auto.commit为TRUE时在kafka中管理偏移的相互矛盾的信息。是否相同的poll（）......

apache-kafka kafka-consumer-api confluent

回答 1 投票 2

如何使用Spring-Kafka使用Confluent Schema注册表读取AVRO消息？

如何使用Spring-Kafka使用Confluent Schema注册表读取AVRO消息？有样品吗？我在官方参考文件中找不到它。

avro spring-kafka confluent confluent-schema-registry

回答 2 投票 3

Kafka在scala中连接avro消费者

我有一个使用kafka connect的生产者，它使用Confluent Kafka Connect API，它以“SourceRecord”格式发布消息，其中包含“schema”和“struct”，如下所示。我正在寻找......

scala apache-kafka-connect confluent

回答 1 投票 0

发生异常主题未找到错误代码 - 汇合

我可以在日志中看到一个错误，即名称为A.Abc-key的主题不存在。我列出了所有主题，并确认A.Abc-key不存在但A.Abc值存在于检查...

apache-kafka avro confluent confluent-schema-registry

回答 1 投票 0

无法在KSql中连接外部主题

我对Confluent KSql很新，但对Kafka来说并不陌生。我将Kafka中存在的主题作为Avro序列化数据。我已启动并运行Confluent模式注册表并将KSql配置为...

apache-kafka confluent ksql

回答 2 投票 1

Kafka Sink HDFS无法识别的令牌

我正在尝试用Kafka HDFS Sink编写JSON。我有以下属性（connect-standalone.properties）：key.converter.schemas.enable = false value.converter.schemas.enable = false schemas ....

apache-kafka apache-kafka-connect confluent

回答 1 投票 0

从avro架构创建hive表时出错

我试图通过从存储在s3中的Avro数据中提取模式来创建一个配置单元表。使用s3 Kafka连接器将数据存储在s3中。我正在向制作人发布一个简单的POJO。 ...

amazon-s3 hive avro apache-kafka-connect confluent

回答 1 投票 0

Kafka connect：基于模式将单个主题接收到多个表

我是Kafka connect的新手。我有一个像下面这样的用例：有一个共享的主题，我得到不同实体的消息，比如员工，部门（实际的表名不同）......

apache-kafka apache-kafka-connect confluent

回答 1 投票 0

Kafka连接器异常错误无法向端点发送HTTP请求：http：// localhost：8081 / subjects / jdbc-source-accounts-value / versions

我使用Confluent Platform 3.3作为Kafka连接器，同时使用以下命令启动连接器./bin/connect-standalone ./etc/schema-registry/connect-avro-standalone.properties ./etc / ...