Confluent Inc.是一家总部位于Palo Alto的软件公司，由在LinkedIn上建立Apache Kafka的团队创建，该公司扩展了Kafka，每天容纳超过1万亿条消息。 Confluent构建了一个基于Apache Kafka的事件流平台，使公司能够轻松地以实时流的形式访问数据。他们的产品范围从完全自我管理的实例到Confluent Cloud。
我试图在不使用Confluent Control Center的情况下这样做，因为我没有许可证。我可以使用dcos任务指标详细信息查看Kafka Broker指标 并看到......
Kafka Connect JDBC Sink - topics.regex无效
我正在使用这个debezium-examples我在我的jdbc-sink.json中添加了“topics.regex”：“CID1122。（。*）”，如下所示{“name”：“jdbc-sink”，“config”：{“ connector.class“：”io.confluent.connect.jdbc ....
连接Confluent Kafka和InfluxDB时出现NullPointerException
我正在尝试使用Confluent InfluxDB Sink Connector将kafka主题中的数据导入我的InfluxDB。首先，我使用nifi从日志文件向kafka主题传输数据，效果很好。 ......
我想问一下我在Mac OS Mojave上安装融合golang kafka客户端的问题。安装golang kafka客户端时为什么总会出现错误消息go -u github.com/confluentinc / ...
我试图从以下URL安装Kafka REST代理，但它有完整的包 - 我只想安装REST客户端，因为我已安装的其他组件已经https：// docs ....
使用汇编5.0.0将Oracle表加载到Kafka时，如何停止将数字转换为字节格式？转换为字节在使用...中的数据时会产生很多问题
我正在运行kafka-connect分布式设置。我正在测试一个机器/进程设置（仍处于分布式模式），工作正常，现在我正在使用3个节点（和3个连接进程），...
我的数据库在另一个Linux节点中，假设xxx.xx.xxx.xxx:3306，我从我的Windows机器运行kafka connect的独立命令。我的server.properties代码是name = test-source -...
汇编：错误无法运行查询表TimestampIncrementingTableQuerier mysql-jdbc
我正在尝试使用MySQL的模式时间戳，行数有限，因为我的表大小是2.6 GB。以下是我正在使用的连接器属性：{“name”：“jdbc_source_mysql_registration_query”...
汇合3.3升级后，Kafka-cassandra连接器出现故障
汇总升级到3.3.0后，Cassandra连接器出现故障。 Cassandra驱动程序的版本是3.3。堆栈如下。 [2017-09-14 08：56：28,123]错误java.lang.reflect ....
如何将Windows中的Kafka（Java）应用程序连接到Linux中的Confluent
我正在使用Winscp和Putty在Linux服务器上运行Confluent 5.0。我在Windows中有Kafka（Java / Eclipse）应用程序。当我运行Java应用程序时，它不能识别Confluent中的Kafka代理...
我设置了一个汇合的s3 sink connect，它在.s3中存储了.avro文件。我转储这些文件，并发现它们只是消息本身，我不知道在哪里可以找到消息密钥，任何想法？ ......
我已经按照这些说明使用Helm图表https://github.com/confluentinc/cp-helm-charts在本地Minikube上安装了Kafka，https：//docs.confluent.io/current/installation / ...
Kafka Connect JDBC Connector - 由于不可恢复的异常而退出WorkerSinkTask
我正在使用JDBC接收器连接器，并在主题中有一个错误的消息。我知道为什么消息是坏的（由于生产者的问题，它由于FK约束违规而失败）。错误 ...
我在EC2机器上的docker容器内运行了一个融合的kafka集群，如下面3个docker容器在单独的EC2实例上，用于动物园管理员和kafka-brokers 1个docker容器在...
通过运行Confluent 5.1.0将数据从Avro文件写入主题。当我运行Kafka使用者命令时，数值不显示。 Ptns-MacBook-Pro：kafka_2.12-2.1.0 ptn $ bin / kafka-console -...
Spring Boot Embedded Kafka无法连接
我正在尝试为我的Kafka消费者编写集成测试。我已经完成了官方参考文档，但是当我开始测试时，我只能看到这个重复的广告无限：-2019 -...
从MySQL到Postgres的Debezium与JDBC Sink - changeforms.route.replacement的更改给出了SinkRecordField错误
我正在使用这个debezium-examples source.json {“name”：“inventory-connector”，“config”：{“connector.class”：“io.debezium.connector.mysql.MySqlConnector”，“tasks.max”： “1”，“数据库....
如何在Confluent中获取有关Zookeeper状态的更多信息
我正在制作Zookeeper集群，我使用：./ bin / zookeeper-server-start等/ kafka / zookeeper.properties分别在Confluent中启动Zookeeper，我想得到Zookeeper的状态。一世 ...