Confluent Inc.是一家总部位于Palo Alto的软件公司，由在LinkedIn上建立Apache Kafka的团队创建，该公司扩展了Kafka，每天容纳超过1万亿条消息。 Confluent构建了一个基于Apache Kafka的事件流平台，使公司能够轻松地以实时流的形式访问数据。他们的产品范围从完全自我管理的实例到Confluent Cloud。
我已将以下行添加到我的server.properties文件中：confluent.support.metrics.enable = false但是，当KSQL启动时，它吐出以下内容：请注意版本检查...
我打算用卡夫卡HDFS连接从卡夫卡消息移动到HDFS。虽然寻找到它，我看到有像齐平的大小和旋转间隔女士使用它你可以批处理参数...
上铺满云卡夫卡流：“segment.ms”，值为“600000”超过1440万分钟限制内部再分配话题
运行在云的汇合与卡夫卡流版本2.1.0获取当卡夫卡流应用程序启动以下错误：java.util.concurrent.ExecutionException：org.apache.kafka.common.errors ....
在使用卡夫卡控制台消费者或KT（GoLang CLI工具，卡夫卡）从卡夫卡的话题费时，我越来越无效字符。 ... \ u0000的\ ufffd？\ u0006app符\ u0000 \ u0000的符\ u0000 \ u0000的符\ u0000 \ u0000的\ ...
[sqlite3的Kafka JDBC源连接器时间戳模式失败
我试图在sqlite中建立一个带有两个表的数据库。我的表中曾经有一个timestamp列。我正在尝试实现时间戳模式以捕获数据库中的增量更改。 Kafka connect ...
蜂房3.1+不从卡夫卡反序列化的Avro 1.8.3+消息1.0+
可以说我有通过卡夫卡创造话题从铺满其中包含的Avro序列化与io.confluent.kafka.streams.serdes.avro.SpecificAvroSerializer然后，我创建一个外部信息流...
我是新来卡夫卡和我很好奇汇合平台。似乎，有没有汇合平台上的许多用户故事。是否融合平台更值添加到卡夫卡...
我有3个卡夫卡集群和我心中已经在其他Clsuter复制的话题。第1个主题为“测试”集群2 test.replica ..我心中已经群集复制3这个话题，但是当我将数据发送到主题“测试”我可以...
我有一个码头工人，撰写文件STAT旋转起来单节点卡夫卡，动物园管理员和架构注册表栈测试我的应用程序。目前，它需要一两分钟来获取堆栈可用; ...
我有使用流1.1.1（计划升级到2.1推出），即合计发布记录压实主题（“客户事件”），由下游的微服务来消耗微服务...
我用卡夫卡-连接-JDBC-4.0.0.jar和卡夫卡连接器的的PostgreSQL-9.4-1206-jdbc41.jar配置连接{ “connector.class”： “io.confluent.connect.jdbc.JdbcSourceConnector”，“模式“：” ...
展望汇合的文件进行安装，安装命令似乎需要sudo的权限。我有几个关于同一个问题：是不是该执行sudo这里需要root权限，或...
Kafka使用（json）消息中的字段连接到Elasticsearch索引的主题
我正在尝试使用Kafka的Connect API中的SMT索引Elasticsearch中的消息。到目前为止，我只是简单地使用主题和时间戳路由器功能。但是，现在我想......
我正在尝试在kubernetes环境中运行融合的kafka映像，并面临致命[KafkaServer id = 0]的错误，在KafkaServer启动期间发生致命错误。准备关闭（kafka.server.KafkaServer）kafka ....
Kafka Connect：JDBC Source Connector：创建具有多个分区的主题
我已经从MySQL创建了一个样本管道轮询数据并写入HDFS（hive表）。由于我的要求，我需要为每个db表创建Source + Connector对。以下我......
kafka添加了在连接器中使用正则表达式的新功能，但似乎在连接器启动后新添加的主题中的主题数据不会被消耗，直到连接器...
如何查找当前为哪个Schema Registry pod /节点的主节点
我在k8s集群上部署了3个架构注册表pod。我试图找到哪个架构注册表pod当前作为主机。我已经找到了通过模式找到master的一种方法...
在特定时间运行Confluent JDBC Connector而不是使用轮询间隔？
我们正在尝试使用Confluent JDBC-Source连接器将数据从数据库表复制到Kafka。问题是该表中的数据每晚都会更新一次，所以我们希望......
Kafka Streams“Consumed.with（）”与KafkaAvroDeserializer
我需要从KafkaAvroDeserializer使用的主题创建一个流，而不是标准的kafka反序列化器。这是因为更进一步，它将被发送到一个主题......
在没有Confluent Platform的情况下使用Apache Kafka时，Avro格式是否可以用于KSQL？
我在文档中看到KSQL通过Confluent Schema注册表支持Avro格式。但是如果使用Apache Kafka（不是Confluent Platform）呢？有没有选择使用Avro ...