-
连接到AVRO架构注册表的SerializationException
我有4个使用者3个在kafka客户端的0.10.0.0版本上,但是其中一个已经移至2.0.0版。 当我调用RestService. -
合计架构注册表UnknownTopicOrPartitionException:此服务器未托管此主题分区。
全新服务器,全新安装的confluent-community-2.12版本5.3.1。 架构注册表配置有<code>/etc/schema-registry/schema -
如何使用Spark结构化流配置Confluent的Schema Registry and Avro序列化程序?
我还没有找到任何文档或示例来说明如何将Schema Registry and Avro序列化程序的设置从Confluent传递到Spark结构 -
Avro模式和阵列
在C#中,我可以定义这两个POCO来定义世代 <pre><code>public class Family { public List<Person> FamilyMembers {g -
向在ECS
我正在使用ECS集群为我们的MSK Kafka集群构建一个托管在Amazon中的冗余架构注册表。 SchemaRegistry Tas -
使用Kafka Connect GCP BigQuery Sink连接器进行表分区
伙计, 我在BigQuery中使用融合连接器进行数据传输。对于每个事件,我都创建了一个Avro模式,该 -
使用Avro序列化器初始化Kafka Producer时出错:java.lang.NoClassDefFoundError
我在获取KafkaProducer实例化以接受值序列化器配置属性的avro序列化器时遇到麻烦。我用安装了<code>kafka -
如何将基本身份验证传递给Confluent Schema Registry?
我想从融合的云主题中读取数据,然后再写入另一个主题。 在本地主机上,我没有遇到任何重大 -
是否可以在没有在ConfluentRegistryAvroDeserializationSchema中给出Reader模式的情况下反序列化Avro消息(使用来自Kafka的消息)
我正在Apache Flink中使用Kafka连接器来访问<em> Confluent Kafka </em>服务的流。 除了架构注册表URL <code>Con -
C#.net核心Confluent.Kafka Avro反序列化
我有一个使用avro生成的类。 avrogen -s customer-v1.avsc。 使用Confluent.Kafka nuget软件包。 我可以序列化Cu -
_schemas主题,架构注册表服务无法启动
我们集群中有<strong> 3台kafka机器</strong>,其中包含<strong> 3个Zookeeper </strong>服务器和<strong> 3个模式注册 -
如何冻结主题的AVRO模式的新版本,以便拒绝不符合要求的消息?
使用Java Client生产者,可以在发布主题之前对消息进行微调以使其符合架构格式。 使用kafka rest代 -
Kafka Streams API如何从Schema Registry获得正确的架构?
我尝试了解Kafka Streams API如何与Schema Registry一起使用。 我知道您在设置应用程序时必须指定架构 -
春季云流融合KStream Avro消费 更新有关空Organization域对象的问题
我正在尝试使用Spring Boot 2.0将来自kafka主题的融合avro消息作为Kstream来使用。 我可以将消息作为<cod -
使用Nifi进行架构注册表维护
我有一个涉及架构注册表和nifi的任务,我有一个主意,但我不确定目前是否可能,或者至少不是最佳实 -
Spark:使用Spark Scala从Kafka读取Avro消息
我正在尝试<code>spark 2.4.3</code>中的以下代码来从kafka中读取Avro消息。 当数据在kafka上发布时,模式 -
使用Kafka配置架构注册表时出现侦听器错误
我正在尝试通过SSL身份验证运行架构注册表服务器,但是在启动服务器时 <pre><code>./schema-registry-start -
使Secure Kafka和Schema注册表相互对话,以及对其进行Spring Boot配置
嘿,我已经尝试解决大约两个星期了。 基本上,我希望kafka在HTTPS的SSL和架构注册表中。不能使用任何人 -
为什么在kubernetes中拆分新的pod后无法重新启动架构注册表
我在kubernetes中运行schema-registry遇到麻烦,想知道是否有人可以解决以下版本不兼容错误。 Confluent的文档 -
根据POJO定义架构,每个主题定义多个架构
现在,我们使用JSON格式向Kafka进行消息传递,现在我将使用Schema Registry将ser / deser格式更改为Avro。 也许 -
配置Kafka Streams应用程序以使用Confluent Schema Registry
我有一个Kafka Streams Java应用程序,该应用程序处理Avro Kafka Topic,对数据进行一些更改,并将处理后的结 -
Confluent Cloud中的邮件值无法正确解码
我对卡夫卡很陌生,并且很融合。我使用自己的虚拟模型编写了与<a href="https://www.confluent.fr/blog/schema-regi -
从jersey-core中排除javax.ws.rs.core
我尝试使用<code>embedded-kafka-schema-registry</code>准备测试,但收到以下异常: <pre><code>[info] java.lang.NoSu -
架构注册表+ _schema主题损坏时的更正是什么
我们有3台kafka机器 每台kafka机器都提供以下服务 <ol> <li>模式注册服务</li> <li> kafka服务</li> <li> -
如何告诉KafkaAvroSerializer与Schema Registry的连接必须通过代理?
我尝试通过curl调用指出我的请求: <strong>架构注册表调用,无需建立任何代理:</strong> <code>curl - -
Kafka Connect-JDBC自定义Avro模式
我正在跟踪有关kafka connect的教程,我想知道是否有可能接收到某种类的消息。 教程:<a href="https:/ -
通过kafka-topics创建的主题是否应该自动创建关联的主题?
我正在尝试模仿“汇合负载”(不建议用于生产用途)以添加连接器,该连接器会自动创建允许创建ksql -
使用SASL_PLAINTEXT Security配置ZK和Broker后,Kafka Schema Registry无法初始化
我们正在使用针对Kafka的Confluent社区版设置,目前我们需要在集群周围配置ACL,因此我们已经配置了zk和B -
Debezium可能会产生无效的架构
我遇到了Avro和Schema Registry的问题。在Debezium创建架构和主题之后,我从Schema Registry下载了该架构。我将 -
每当我重新启动系统时,它都会显示'utf-8'编解码器无法解码kafka中的字节0x98以产生火花
这是我下面的代码,用于从kafka获取数据以进行流式传输 首先它正在运行,但是当我重新启动系统时,