我编写了docker-compose.yml文件来创建以下容器：
我想要一个单一的码头-合成文件，以旋转必要的容器，公开所需的端口和互连依赖的容器目标是让我使用来自码头枢纽的官方合流图像。at io.confluent.kafka.schemaregistry.storage.KafkaStore.getBrokerEndpoints(KafkaStore.java:254)<init>(KafkaSto
浏览 2提问于2017-05-17得票数 0
key.converter=io.confluent.connect.replicator.util.ByteArrayConverter value.converter=io.confluent.connect.replicator.util.ByteArrayConverterException in thread "main" org.apache.kafka.common.config.ConfigException: Invalid value io.confluent.connect.replicator.u
浏览 7提问于2017-06-28得票数 1
1回答
(TopicsResource.java:147) at org.eclipse.jetty.io.AbstractConnection$2.run(AbstractConnection.java:109)
at io.conflue
浏览 1提问于2018-08-06得票数 0
回答已采纳
我曾尝试使用https://doctoolchain.github.io/docToolchain/创建包含swagger/openapi yaml文件的HTML或PDF文档。它看起来唯一的输出是成合流，这也需要一个额外的合流插件。这是目前唯一的选择吗？我可以使用docToolchain做其他的asciidoc和图表格式化，我会很高兴包括swagger。
浏览 79提问于2021-08-04得票数 3
我正在使用java中的basic Avro publisher，这在示例中是可用的。
我有一个合流云访问，在这里我尝试用同样的例子，但它是显示垃圾字符的价值。手动创建主题的transactionsConfiguration文件是使用以下条目创建的
configuration.I 通过传递绝对文件路径来运行java应用程序，能够看到模式也是在合流</em
浏览 4提问于2020-09-10得票数 2
回答已采纳
如何编写kafka avro序列化器和解析器(即使用io.confluent.kafka.serializers.KafkaAvroDeserializer) from("kafka:localhosttopic=customer_payment&groupId=group1&specificAvroReader="+ true+
"&keyDeserializer=io.confluent.kafka.serializers.KafkaAvroDeserializer&v
浏览 26提问于2019-06-07得票数 0
回答已采纳
对于模式验证，我使用合流模式注册表。我以前在5.2.0版本中使用了这个库(也尝试了其他5.x.x版本)： <groupId>io.confluent</groupId>我有以下错误：
Caused by: java.lang.NoClassDefFoundError: Could not initialize class io.confluent.kafka.serializers.KafkaAvroSerial
浏览 6提问于2021-09-07得票数 0
回答已采纳
1回答
at io.confluent.kafka.schemaregistry.storage.KafkaStore.filterBrokerEndpoints(KafkaStore.java:271)<init>(KafkaStore.java:122) at io<
浏览 0提问于2018-11-07得票数 1
是否有适用于流行编码标准(例如或)的ReSharper .dotSettings文件？
浏览 1提问于2017-09-19得票数 1
我正在使用:0.24.0使用以下代码在合流云上查询ksqlDb at java.base/java.lang.Class.getDeclaredMethods0(Native(ClassUtil.java:1231)
... 88
浏览 16提问于2022-03-08得票数 0
2回答
我已经在Ubuntu16.04机器上安装了汇合平台，最初我已经配置了动物园管理员、Kafka和ksql，并启动了合流平台。我能看到下面的信息。(SchemaRegistryRestApplication.java:39) at io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain
浏览 2提问于2019-01-30得票数 5
1回答
我目前正在工作的设置
NiFi流Avro消息(合流模式注册表引用)到Kafka(v2.0.0，20个分区，合流v5.0.0)，Kafka工作者(HDFS接收器)以flush.size=70000格式将这些消息流到, leaderId=3, fetcherId=0] Error sending fetch request (sessionId=1661483807, epoch=374) to node 3: java.io.IOExceptionREAD_UNCOMMITTED, toForget=, metadata=(
浏览 0提问于2019-05-27得票数 2
回答已采纳
1回答
我希望在我的Java/Spring服务中使用，并且我需要生成合流序列化消息，因为我有使用汇合API来使用我的消息的.NET和NodeJS客户机。与Spring和合流
kafkaconfiguration:
schema.registry.url: http://127.0.0.1:8081
浏览 0提问于2019-05-02得票数 1
回答已采纳
我正在探索合流卡夫卡，并遵循这一快速启动指南从。每当我尝试使用以下命令为Kafka主题创建一些示例数据时，我都会得到java.lang.ClassNotFoundException: io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor<init>(KafkaProducer.java:320)
at io.confluent.ksql.datagen.DataGenProducer.popu
浏览 1提问于2018-08-01得票数 0
回答已采纳
有时，在过去的几天里，我的合流页面经常崩溃。日志(合流\日志\catalina.2014-05-06)显示如下：java.lang.OutOfMemoryError: Java heap
浏览 0提问于2014-05-06得票数 5
回答已采纳
我从正式的合流站点下载了汇流版本的.tz (我在MAC上)，并遵循本地 (1节点)的设置，并且本地(1节点)和模式注册中心(SchemaRegistry)的设置很好，但是架构注册中心(SchemaRegistry(KafkaSchemaRegistry.java:1488) at io</em
浏览 3提问于2021-11-04得票数 0
回答已采纳
在为Kafka进程设置各种堆、GC等java参数时，似乎存在相互冲突的思想流派。 -XX:MinMetaspaceFreeRatio=50 -XX:MaxMetaspaceFreeRatio=80
官方的合流党路线是在哪里设置这些
浏览 0提问于2016-09-20得票数 0
回答已采纳
我想在亚马逊网络服务的EC2环境中使用confluent。我如何安装它。我已经在我的本地尝试了confluent cli，并想复制这个将sql连接到kafka的功能。有关于这方面的文档吗？
浏览 23提问于2019-05-15得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
