Confluent Inc.是一家总部位于Palo Alto的软件公司，由在LinkedIn上建立Apache Kafka的团队创建，该公司扩展了Kafka，每天容纳超过1万亿条消息。 Confluent构建了一个基于Apache Kafka的事件流平台，使公司能够轻松地以实时流的形式访问数据。他们的产品范围从完全自我管理的实例到Confluent Cloud。
Confluent的kafka-avro-console-consumer在哪里写日志文件？
我正在运行Confluent的kafka-avro-console-consumer，如快速入门教程中所述：kafka-avro-console-consumer --topic test --zookeeper localhost：2181 - from-beginning然而，我有......
我在kubernetes集群上的容器中运行了kafka，zookeeper，schema-registry和ksql。 Kafka，zookeeper和schema注册表运行正常，可以在Avro中创建主题和写入数据...
我们需要使用JDBC Connector从RDBMS读取数据，然后在将数据推送到Kafka之前使用我们的自定义加密。并在解决方案中解密数据，然后将其推送到...
升级到Confluent 4.1后，Schema Registry将无法启动
我最近将Confluent升级到4.1，但架构注册表似乎有一些问题。在汇合开始时，schema-registry（以及ksql-server）无法启动。这是我在...中得到的错误
我们正在尝试将SQL-Server JDBC Connector与KafkaAvroSerializer一起使用，并在将数据发送到Kafka之前提供Customized ProducerInterceptor来加密数据。在消费者方面，我们想要使用......
Confluent 3.3无法使用kafka-avro-console-producer本地连接到schema-registry
在下载汇合的开源3.3之后在命令行进行简单的实验：汇合启动 - 启动所有服务而没有任何明显的错误：汇合-3.3.0％汇合启动...
使用kafka-avro-console-consumer将Avro记录为二进制数组
我有一个Kafka Producer，它将Avro记录发送到“测试”主题。我还有一个Schema Registry，其中存储了每个记录的模式。之后，我使用命令kafka-avro-console-consumer -...
使用kafka-avro-console-consumer消耗spring spring stream kafka发送的avro消息时出错
我尝试使用我本地安装的汇合4.0.0的官方模式 - 注册表 - 汇合示例（使用者/制作者），它可以在发送发送请求时发送“sensor”avro消息并在侦听器中接收，但是...
尝试启动zookeeper服务器时出错 - Confluent设置
我想在Ubuntu 16.04上设置Confluent-4.1.1。要启动ZooKeeper服务器，我从Confluent的根目录运行./bin/zookeeper-server-start ./etc/kafka/zookeeper.properties.txt by ...
我正在尝试轮询temp的文件大小。从Kafka主题写入HDFS的avro文件，但是org.apache.hadoop.fs.FileStatus保持返回0字节（.getLen（）），而编写器是......
我正在使用PostgreSQL。在我的表格数字列中定义如下：“net_weight”numeric（19,2）但是在Kafka中，我收到的不是十进制数字（例如14.0）我得到类似“E4g =”的东西......
我在MacOS上运行本地版本的Confluent（4.0）并在启动它并创建一个主题newtopic并转到http：// localhost：18081 / subjects / newtopic - 获取以下错误：{“...
我总共有3个VM（CloudVPS）。他们每个人都安装了java，汇合的开源。在VM1中，我正在运行3个Splunk-sink-connector进程，它可以读取不同的主题并且...
如何将Confluent Control Center Interceptor添加到现有S3（Sink）连接器？监视接收器。我正在寻找文件。任何帮助表示赞赏。
如何使用Confluent Control Center的Web界面？
我在Linux VM上的单个云上部署了汇合，我计划为消费者配置拦截器。但是如何配置Control Center以访问其Web界面？部署......
我试图实现商店时收到异常。我正在运行Kafka 1.0，Confluent的Schema Registry 4.0和Avro 1.8.2。我用Avro的maven插件生成了Pojo并部署了......
Apache Kafka 1.0.0 Streams API Multiple Multilevel groupby
如何在Kafka Streams API中使用带有多个约束的.groupby。与Java 8 Streams API示例相同，public void twoLevelGrouping（List 人的）{final Map
使用JsonConverter的Kafka Connect HDFS Sink for JSON格式
通过JSON向Kafka制作/消费。使用以下属性保存到JSON中的HDFS：key.converter = org.apache.kafka.connect.json.JsonConverter value.converter = org.apache.kafka.connect.json ....
我正在尝试使用kafka-jdbc-connector（源和接收器）和一个非常古老的数据库（cloudscape）。我有这个数据库的JDBC驱动程序。我把驱动程序放在“/ share / java / kafka / connect / jdbc”中......
Kafka SMT ValueToKey - 如何使用多个值作为关键？
我正在使用Confluent JDBCSourceConnector从Oracle表中读取。我正在尝试使用SMT生成由3个连接字段组成的密钥。 transforms = createKey transforms.createKey.type = ...