腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(3057)
视频
沙龙
2
回答
FlinkKafkaConsumer/Producer & Confluent
模式
注册
表:验证失败&兼容性
模式
写入无效
模式
apache-kafka
、
apache-flink
、
avro
、
flink-streaming
、
confluent-schema-registry
你好,im正在(反)序列化一个简单
的
avro
模式
和
模式
注册
中心
。设置: 目标:
生产者
应该发送一条用ConfluentRegistryAvroSerializationSchema到目前为止,还
浏览 9
提问于2021-06-01
得票数 1
1
回答
生产者
是否与代理
和
架构
注册
中心
建立了两种
不同
的
连接?如果是,这是HTTP连接吗?
apache-kafka
、
confluent-schema-registry
我正在使用Spring-
Kafka
2.2.7.RELEASE,并且有一个
生产者
和
消费者。我
的
集群有动物园管理员、代理
和
一个shema
注册
中心
来处理avro
模式
验证。因此,在我
的
生产者
配置中,我将传递代理URL
和
Schema。现在我有几个问题, 在发布/
生成
消息
时,
生产者
是与代理
和
模式
注册</e
浏览 2
提问于2019-12-24
得票数 0
回答已采纳
2
回答
如何
在合流
模式
注册
表中
的
主题
之前创建avro
模式
(键/值)?
apache-kafka
、
confluent-schema-registry
我有卡夫卡制片人
的
申请。是否可以在
主题
之前使用创建架构?无论
如何
,api
浏览 5
提问于2022-08-01
得票数 0
回答已采纳
2
回答
如何
在团队之间共享avro
模式
定义
apache-kafka
、
avro
、
confluent-platform
、
confluent-schema-registry
Kafka
模式
-
注册
表提供了一种使用通用数据契约序列化
和
反序列化
Kafka
数据
的
好方法。但是,数据契约(.avsc文件)是
生产者
和
消费者之间
的
粘合剂。一旦producer
生成
了.avsc文件,它就可以签入到
生产者
端
的
版本控制中。根据语言,它也自动
生成
类。 什么是消费者拉下
模式
定义以供参考
的
最佳机制?对于avro,有类
浏览 0
提问于2019-09-05
得票数 4
回答已采纳
4
回答
如何
从
自动测试中验证
Kafka
消息
内容?
apache-kafka
我有几个有消费者
和
生产者
的话题。我想确保一个
不同
的
应用程序发布正确
的
信息给
kafka
。因此,这在某种程度上介于集成
和
单元测试之间,因为我只想测试
生产者
将正确
的
内容放入
kafka
中。有效
的
测试是: app
生成
并发送另一条
消息
到另一个
浏览 3
提问于2017-06-06
得票数 4
1
回答
是否有方法为每个
主题
指定引导服务器
和
模式
注册
表?
spring
、
apache-kafka
、
spring-kafka
我遇到了一个问题,我在spring中有一个应用程序,这个应用程序从一个
主题
中消耗,在另一个
主题
中
生成
。spring.
kafka
.bootstrap-servers=local
浏览 5
提问于2022-11-08
得票数 0
1
回答
从
架构
注册
表自动创建
主题
-
主题
找不到
apache-kafka
、
confluent-schema-registry
我有
模式
注册
表容器http://registry-server:8081 bootstrap.servers : [PLAINTEXT://
kafka
-server:9092]以及充当
生产者
的
service试图
向
<e
浏览 7
提问于2022-09-02
得票数 1
回答已采纳
2
回答
Kafka
应用程序无法
从
模式
注册
表中检索正确
的
模式
id。
apache-kafka
、
avro
、
confluent-schema-registry
not foundio.confluent.rest.exceptions.RestNotFoundException: Schema 16 not found我想知道为什么应用程序试图找到
模式
16,它在哪里找到这个号码?它是否存储在应用程序缓存或
Kafka
Broker/Schema
注册
表上
的
一些内部日志中
浏览 5
提问于2022-07-25
得票数 0
1
回答
如何
将红熊猫群集
和
主题
连接到红熊猫架构
注册
表?
apache-kafka
、
schema
、
confluent-schema-registry
、
redpanda
我正在尝试将运行中
的
红熊猫卡夫卡集群连接到一个红熊猫
模式
注册
中心
,以便
模式
注册
表验证来自
主题
的
传入
消息
和
/或
从
主题
读取
的
消息
。我能够
向
注册
表添加一个
模式
,并使用curl请求读取它,还可以将
消息
添加到我在红熊猫集群中创建
的
kafka
浏览 6
提问于2022-01-06
得票数 0
1
回答
如何
从
同一个
生产者
向
不同
的
Kafka
主题
和
模式
注册
中心
生成
消息
java
、
apache-kafka
、
kafka-producer-api
、
confluent-schema-registry
我正在尝试在我
的
Java应用程序中
从
相同
的
生产者
向
不同
的
kafka
主题
生成
消息
。 这就是我创建我
的
生产者
并向
主题
发送
消息
的
方式。producer.send(topic1, genericRecord, datasetId1); producer.send(topic2, genericRecord, datas
浏览 46
提问于2021-10-28
得票数 0
1
回答
如何
在消费前获取
模式
?
python
、
apache-kafka
、
confluent-schema-registry
、
confluent-kafka-python
我使用python confluent-
kafka
1.5.0
和
模式
注册
表来消费来自
kafka
的
avro
消息
。 我只是消费者,没有访问管理
生产者
或经纪人或其他东西。我知道
主题
名称,并从
消息
字段中获取
主题
和
命名空间,还可以在架构
注册
表客户端、sr客户端使用schema_id
从
消息
中获取架构。根据我
的
目标,在我开始
浏览 10
提问于2021-10-09
得票数 0
1
回答
当使用Avro + schema时,
如何
从
模式
定义中获益来序列化/反序列化
消息
?
apache-kafka
、
avro
、
confluent-platform
、
confluent-schema-registry
我正在学习卡夫卡,对我来说,用阿夫罗有一个有图式的卡夫卡
主题
是有意义
的
。但是,当谈到将
模式
定义放在哪里时,我遗漏了一些东西: 如果我使用
模式
注册
中心
浏览 1
提问于2017-06-28
得票数 2
回答已采纳
1
回答
合流
模式
注册
表母版
apache-kafka
、
confluent-platform
、
confluent-schema-registry
对于跨网络融合平台,我们有一个卡夫卡集群
的
前提
和
另一个在AWS上
的
数据被复制
从
-prem到AWS使用镜像制造商。这两个集群都独立于它们自己
的
模式
--
注册
表、rest代理
和
connect.Both集群有
不同
的
生产者
和
使用者集,并且有选择
的
主题
在集群之间被镜像。 部署
模式
注册
中心
的</em
浏览 0
提问于2019-07-10
得票数 1
回答已采纳
2
回答
如何
使用KafkaTemplate设置
消息
头?
java
、
spring-boot
、
apache-kafka
、
spring-kafka
我正在构建一个Spring Boot 2.4.4应用程序,使用
模式
验证
向
Kafka
(Confluent Platform)
生成
消息
。该
模式
是在该
主题
的
模式
注册
表中设置
的
,我已经使用Maven Avro插件
从
相关
的
AVSC文件创建了POJO (LoanInitiate)。.build(); kafkaTemplate2.send(topic, messa
浏览 293
提问于2021-04-23
得票数 1
2
回答
使用topic启用ACL
的
Kafka
java
生产者
和
消费者
java
、
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
我对
kafka
ACL配置有点困惑,在
kafka
ACL配置中,我们为
生产者
和
消费者配置授权。有各种使用命令行
生成
/消费
消息
的
示例。我们是否需要任何额外
的
配置来使用JAVA api
向
/
从
安全
的
kafka
主题
生成
/消费
消息
。
浏览 2
提问于2016-06-15
得票数 0
1
回答
如何
从
收到
的
kafka
消息
中获取Avro
模式
对象?
apache-kafka
、
avro
、
kafka-consumer-api
我试图
向
kafka
发布/使用我
的
java对象。我使用Avro
模式
。 我
的
基本程序很好。在我
的
程序中,我在
生产者
(编码)
和
使用者(解码)中使用我
的
模式
。如果我在接收端将
不同
的
对象发布到
不同
的
主题
(例如:100个
主题
),我不知道我收到了什么类型
的
消息
?我想从接收到<em
浏览 1
提问于2016-04-15
得票数 0
回答已采纳
1
回答
卡夫卡消费者
从
哪里获得第一个版本
的
Avro
模式
?
apache-kafka
、
avro
、
quarkus
说明Avro和服务
注册
中心
使用情况
的
大多数Quarkus示例将消费者
和
生产者
结合在
同一个
项目中。在这样做时,
模式
和
生成
的
类对
生产者
和
使用者都是可用
的
。我理解
模式
注册
中心
的
作用是维护
模式
的
各种版本,并将它们提供给消费者。 我不完全理解
的
是使用
浏览 10
提问于2022-07-23
得票数 0
2
回答
用SpringBoot测试SpringBoot @sendTo
spring-boot
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
、
kafka-producer-api
我正在使用@SendTo("example")注释
向
主题
发送
消息
,但我不知道
如何
测试它。我打开一个控制台
生产者
在控制台中似乎可以工作,但是我在
生产者
中没有收到任何
消息
gid: trace= span= [
kafka
-producer-network-thr
浏览 9
提问于2020-04-09
得票数 1
回答已采纳
1
回答
如何
从
原始缓冲区对象
Kafka
java中获取字符串
消息
java
、
node.js
、
apache-kafka
、
node-kafka
当卡夫卡
的
消费者消费了卡夫卡
的
信息时,看起来- {"type":"Buffer","data":[91,13 .....]当我在nodejs消费者中使用m.message.value.toString('utf8')时,它会打印实际
消息
。但我需要在java
Kafka
消费中消费。我试过用property.put("value.serializer.encoding", "utf8")
和
n
浏览 0
提问于2019-03-11
得票数 0
1
回答
生产者
如何
与
注册
表通信,以及它
向
注册
表发送了什么?
apache-kafka
、
protocol-buffers
、
confluent-schema-registry
url,然后
生产者
将知道它将
向
注册
表发送联系人,以便
向
注册
表提供有关
消息
的
一些元数据。现在,我想更好地理解这是
如何
工作
的
,
生产者
和
注册
表之间交换了什么(或者
kafka
是否与
注册
表有联系)? 总之,我
的
问题是,想象一下,我有一个记录,是一个原型格式。我要把这个原型放在卡夫卡
的
某个话题里。现在我想激活
模式<
浏览 4
提问于2020-09-22
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka权威指南(一):初识Kafka
“事件驱动架构”Apache Kafka中的事务
“消息中间件”Apache Kafka中的事务
“Kafka技术”Apache Kafka中的事务
系统解读Kafka的流和表(二):主题、分区和存储
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券