腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
3
回答
使用
反射
的
avro
SpecificRecord
的
KafkaConsumer
泛
型
类型
java
、
reflection
、
apache-kafka
、
avro
我想
使用
反射
加载
的
类来初始化
KafkaConsumer
泛
型
类型
。这些类将通过
avro
-tools生成,并将扩展SpecificRecordBase类。我知道,我可以用通配符做一些事情-
KafkaConsumer
<? extends SpecificRecordBase, ?extends SpecificRecordBase> consumer = new
KafkaConsumer
<>(p
浏览 68
提问于2020-12-22
得票数 2
2
回答
Flink -将
Avro
数据转换为表
java
、
apache-flink
、
flink-streaming
、
flink-sql
我有卡夫卡
的
阿夫罗格式
的
留言。它们必须转换为表,然后
使用
SQL进行选择,然后转换为流,最后转换为接收器。有多个具有不同
Avro
模式
的
Kafka主题,因此需要动态表。这是我正在
使用
的
代码StreamTableEnvironment tableEnv = StreamTableEnvironment.createMyAvroClass是
Avro
类,它扩展了SpecificReco
浏览 0
提问于2020-12-29
得票数 2
2
回答
卡夫卡消费者钻石经营者无法推断论点
java
、
spring
、
generics
、
apache-kafka
、
spring-kafka
上面提到
的
代码在我
的
示例POC项目上运行得很好。 final Consumer<Long, String> consumer = new
KafkaConsumer
浏览 0
提问于2020-05-31
得票数 0
回答已采纳
2
回答
如何动态地指定Java
泛
型
类
java
、
kafka-consumer-api
、
generic-programming
如果我指定了一个返回
泛
型
类
的
方法,除了动态地指定
泛
型
类
的
类型
之外,我还能做什么呢?try { Class d= Class.forName(valuetype);
KafkaConsumer
<c,d> consumerconsumer = new
KafkaConsumer
<c,d>(Propert
浏览 2
提问于2018-08-30
得票数 2
1
回答
与Kafka、Quarkus和
Avro
在同一主题中
的
多个事件
类型
java
、
apache-kafka
、
avro
、
quarkus
、
microprofile
我正在尝试
使用
Quarkus从主题中读取事件。主题可以包含不同
类型
的
事件。所有事件都
使用
AVRO
格式,因此我有一个模式注册表,我可以在其中读取事件
的
相关模式。我
使用
avro
-maven-plugin将模式编译成Java类。假设我们有两种
类型
的
事件,它们
的
模式如下: Event1 {} Event2 { &qu
浏览 23
提问于2020-10-14
得票数 0
1
回答
使用
kotlin方差
的
未知
类型
方差
kotlin
、
generics
我
使用
泛
型
不是为了重用代码,而且我对
类型
泛
型
缺乏理解。我有一个类编写器(来自另一个库
的
java代码)。public class Writer<T>public class FileWriter<D>{ FileWriter(WriterfunDoSomethingExtra(writer: FileWriter<in
SpecificRecord<
浏览 6
提问于2021-02-22
得票数 1
1
回答
SpecificRecord
的
Flink AvroDeserializationSchema --与
泛
型
类
类型
一起
使用
apache-flink
、
avro
目标:我想实现一个可以重用
的
函数,它可以基于作为
类型
参数传递
的
生成类来创建特定记录
的
AvroDeserializationSchema。生成
的
类是
使用
AvroHugger和继承SpecificRecordBase生成
的
。 问题:无法找到设置
泛
型
类型
参数以使编译工作
的
方法。AvroDeserializationSchema.forSpecific需要获取一个类作为生成
的
参数。regi
浏览 60
提问于2020-09-08
得票数 0
1
回答
Java -通过为SpecificAvroSerde输入动态更改Kafka数据
类型
java
、
apache-kafka
、
kafka-consumer-api
、
avro
、
avsc
= new StreamsBuilder();我
的
KafkaDataType是一个由关联
的
.avsc文件自动生成
的
avro
模式。我
的
理解是KafkaDataType必须是预先定义
的
.但是,是否有允许动态或通用KafkaDataType
的
现有方法?如果是这样的话,最好
使用
一个示例代码块。我们<
浏览 5
提问于2021-11-03
得票数 0
回答已采纳
2
回答
使用
Avro
将GenericRecord转换为
SpecificRecord
对象
c#
、
.net-core
、
avro
、
confluent-platform
我
使用
Confluent.Kafka.
Avro
在Apache Kafka
的
生产者和消费者之间进行序列化。在生产者中,我
使用
特定记录,但在消费者端,我希望将所有记录作为通用记录
使用
,然后将它们转换为特定记录。有没有办法自动做到这一点?或者需要实现所有这些转换?
浏览 0
提问于2018-08-23
得票数 0
1
回答
在中实现
Avro
avro
、
spring-cloud-stream
、
spring-cloud-dataflow
我正在尝试实现流,它从数据库中读取记录,将这些记录传递给处理器,后者将转换为
Avro
模式,然后将其传递给接收器应用程序
使用
。我将数据从SQL DB传输到我
的
源应用程序,并通过Kafka绑定程序传递数据,没有问题,我正在将数据从处理器发送到Sink应用程序,
使用
Avro
序列化/反序列化。我创建了一个名为ech.avsc
的
avro
模式,并
使用
处理器中
的
avro
插件为其生成了一个名为EchRecord
的<
浏览 3
提问于2017-11-20
得票数 0
回答已采纳
3
回答
使用
反射
将pojo写到拼图文件
apache
、
hadoop
、
serialization
、
avro
、
parquet
我能够
使用
反射
生成
avro
模式,然后
使用
AvroSchemaConverter创建拼花模式。另外,我无法找到一种将Pojos转换为GenericRecords (
avro
)
的
方法,否则我可以
使用
AvroParquetWriter将Pojos写成块文件。有什么建议吗?
浏览 11
提问于2014-10-18
得票数 5
回答已采纳
1
回答
如何通过
反射
获取
泛
型
参数
的
类型
c#
、
reflection
、
methodinfo
、
generic-method
我需要通过
反射
获取
泛
型
参数
的
泛
型
类型
。而不是
类型
{ Name="T“;FullName=null }{ Type[] types = basee.GetGenericArguments();但是我不能
使用
typeof(
浏览 5
提问于2012-09-08
得票数 1
2
回答
在Flink Mini Cluster (1.11)和AvroKryoSerializerUtils上运行流不起作用
apache-flink
在集成测试中测试flink mini集群上
的
流时,我遇到了一个问题。该流映射一个生成
的
Avro
Java类(
SpecificRecord
)。 流作业是用Scala编写
的
。Pojo类,因为该类中嵌套了多个
Avro
Pojo类。我尝试为所有嵌套
的
Pojo类
类型
添加所有
类型
信息,但仍然遇到相同
的
问题。 所以现在我想知道是否有人
使用
生成
的
Avro
Pojo类和嵌套<e
浏览 38
提问于2020-09-25
得票数 0
2
回答
使用
Avro
的
无法正确转换字符串消息
spring-cloud-stream
这个问题发生在我设置了
Avro
消息转换器之后。如果我删除
Avro
消息转换器并
使用
StreamListener来处理消息转换,它将很好地工作。spring.cloud.stream.bindings.toGreeting.destination=greeting spring.cloud.stream.bindings.toGreeting.contentType=application/*+
avro
spring.cloud.stream.schema.
avro
.dynamicSchemaGene
浏览 13
提问于2017-06-28
得票数 0
回答已采纳
4
回答
Kafka
Avro
使用
模式注册表失败将序列化/反序列化为具体
类型
java
、
apache-kafka
、
avro
、
confluent-platform
、
confluent-schema-registry
我似乎无法在其具体
的
avro
实现中
使用
消息,我得到了以下例外:下面是代码(我
使用
Spring Boot)private final KafkaTemplate<String,同样重要
的
是要注意
的
是,我没有亲自注册模式,而是让我
浏览 3
提问于2020-02-21
得票数 2
2
回答
如何在
Avro
中为兼容模式从GenericRecord转换为
SpecificRecord
java
、
avro
Avro
SpecificRecord
(即生成
的
java类)是否与模式演化兼容?也就是说,如果我有一个
Avro
消息
的
来源(在我
的
例子中是kafka),并且我想将这些消息反序列化为一个特定
的
记录,那么是否可以安全地进行呢?如果我能够找到新
的
模式(例如
使用
合流模式注册表),我可以反序列化到GenericRecord,但是似乎没有一种方法可以从
泛
型
记录映射到不同模式
的
特定记录。MySp
浏览 3
提问于2015-11-26
得票数 14
回答已采纳
2
回答
如何避免此java
泛
型
警告
java
、
generics
f : klass.getFields() ) { }} 如果删除方法签名中
的
泛
型
类型
,则该方法
的
行为相同,除非您收到
使用
原始
类型
的
警告。我遇到过其他类似的事情,特别是关于
反射
,您不一定有输入
类型
。
反射
似乎只是在
泛
型
方面自然会出现问题,因为<
浏览 2
提问于2010-02-04
得票数 4
回答已采纳
2
回答
Java中
类型
擦除
的
例外情况是什么?
java
、
generics
、
reflection
、
type-erasure
我在网上看到过一些地方提到,在某些情况下,可以
使用
反射
API来获取有关
泛
型
数据
类型
的
信息,我认为这些信息会通过
类型
擦除而丢失。我正在寻找
类型
擦除不完整
的
情况
的
完整列表,即某些东西仍然可以通过
反射
访问。可以获得
泛
型
类型
的
示例和相关
反射
代码
的
好列表将是很好
的
。 UPDATE 正是
浏览 2
提问于2012-08-06
得票数 3
回答已采纳
1
回答
为具有
泛
型
类型
的
Java POJO生成
Avro
架构
java
、
generics
、
reflection
、
avro
我正在尝试
使用
以下方法在运行时获取
Avro
Schema: Schema s = ReflectData.get(clazz); return avroSchema.getAvroSchema();但由于我
的
POJO类包含如下
泛
型
: public abstract class Data<T> im
浏览 42
提问于2019-11-28
得票数 0
1
回答
如何从泽西发送/接收阿夫罗格式
的
数据?
json
、
performance
、
protocol-buffers
、
jersey-2.0
、
avro
我有一套
使用
jersey开发
的
web服务,目前web服务以JSON格式发送和接收数据。为了提高处理时间和所需内存
的
性能,我们正在试验Protobuf和
avro
。我发现了一些教程,这些教程展示了将protobuf集成到这样
的
web服务中是多么容易。但是,我找不到这样
的
教程或任何一本书,它至少能让我知道我们是否可以
使用
avro
格式
使用
jersey发送/接收数据。 我想知道如何
使用
avro
格式<
浏览 0
提问于2014-07-21
得票数 2
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
如何通过Java反射获取泛型类型信息
Java中如何获得A泛型中T的运行时类型及原理探究
编程小知识【java-0005】java泛型机制-泛型方法
学习 Java 中最困难的部分以及如何克服它们
Java核心技术 PDF 高清电子书
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券