云消息队列 Kafka 版partition 的相关内容

返回频道云消息队列 Kafka 版partition

问答 2021-12-07 来自：开发者社区

Flink kafka Consumer的topic和partition动态发现是什么？

问答 2021-12-07 来自：开发者社区

Kafka里的partition属于什么类型，有什么作用呢？

问答 2021-12-07 来自：开发者社区

kafka中的produce为partition指定的值有什么作用？

问答 2021-12-06 来自：开发者社区

Flink 读取 Kafka 多个 Partition 问题，如何解决

如题，请大佬解答*来自志愿者整理的flink

问答 2021-12-03 来自：开发者社区

link 读取 Kafka多个 Partition问题是什么情况？

我的 Kafka cluster 有三个机器，topic 也分了三个 partition，我用 Flink 读取 Kafka 消息的时候，感觉只从一个 partition 读取了东西，一开始我的 bootstrap.servers 只写了一个地址，现在改成了所有地址，也换了 group.id Properties properties = new Properties(); pr...

问答 2021-12-02 来自：开发者社区

对于kafka partition 设置时间戳及watermark

我按官网操作，重写了序列化方式 val kafkaSource = new FlinkKafkaConsumer09[MyType]("myTopic", schema, props)kafkaSource.assignTimestampsAndWatermarks(new AscendingTimestampExtractor[MyType] { def extractAscendin...

问答 2020-06-06 来自：开发者社区

关于kafka创建topic后partition的奇怪问题,求大神?报错

有一些数据需要在在Java中调用API发送到指定的topic中的指定partition中,报出如下错误: 错误说我的partition超出了最大的partition数量.可以确定partition的数量是我创建的为50个,奇怪的是在kafka中查询partition数量的时候,有时候查询出3个有时候查询出50个,如图并且第一个报错也是,有时是可以将数据放进去的如图: 有一些p...

问答 2019-12-11 来自：开发者社区

kafka的partition是不是应该和slot一一对应？我的一个和window有关的应用在slo

kafka的partition是不是应该和slot一一对应？我的一个和window有关的应用在slot数目不等于partition的时候会不出结果，另一个单纯读写的应用使用一个slot消费全部partition是可以的。您聊不了解这里面的机制？本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。点击这里欢迎加入感兴趣的技术领域群。

问答 2019-11-22 来自：开发者社区