Loading [MathJax]/jax/input/TeX/config.js

开发者社区

文档建议反馈控制台

文章/答案/技术大牛

发布

社区首页 >问答首页 >卡夫卡除法器用值代替键

问卡夫卡除法器用值代替键
EN

Stack Overflow用户

提问于 2022-06-13 06:02:47

回答 1查看 79关注 0票数 0

我有一个特殊的情况，我需要确保parent键的所有消息都转到特定的分区。假设键有以下属性

pk：UUID

对于价值来说

parent：String
name：String
familyName：String
等。

在此之前，我已经实现了其他分区，但我总是能够从关键部分获取相关信息。接口org.apache.kafka.clients.producerPartitioner显示方法分区的可能性键和值。但是，它也表示它们都可以是空的。

我之所以这样问，是因为流的内容稍后也会加载到物化视图中。这个视图应该允许搜索"pk“。如果我也要在键中包含parent属性，我就不能再搜索pk了，除非我也有parent。

下面是如何在流处理拓扑中设置物化视图：

KTable<MyObjectKey, MyObjectValue> myObjects = builder
  .table("topicName", Consumed.with(myObjectKeySerde, myObjectValueSerde),
         Materialized.<MyObjectKey, MyObjectValue, KeyValueStore<Bytes, byte[]>>as("viewName")
           .withKeySerde(myObjectKeySerde)
           .withValueSerde(myObjectValueSerde));

稍后我可以访问它，就像

final MyObjectKey pk = MyObjectKey.newBuilder().setUUID(... UUID searched for).build();
final ReadOnlyKeyValueStore<MyObjectKey, MyObjectValue> store =
  streamsBuilderFactoryBean.getKafkaStreams()
    .store( fromNameAndType("viewName", keyValueStore()));
MyObjectValue value = store.get(pk);

理论上，可以使用范围查询，然后允许我在键中包含parent。这样，我就会从pk+ 00000000-0000-0000-0000-000000000000搜索到pk+ ffffffff-ffff-ffff-ffff-ffffffffffff。

apache-kafka-streams

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2022-06-13 14:31:33

确保父键的所有消息都指向特定的分区。

Partitioner将是正确的方法。

方法同时划分可能的键和值。但是，它也表示它们都可以是空的。

如果您完全控制生产者使用分区，这不应该是一个问题。我不认为键和值都是空的，至少在需要非空键的状态存储区是不可能的。

如果您构建简单字符串parent:pk之类的键，那么使用ReadOnlyKeyValueStore#prefixScan，这将允许您获取特定父前缀的所有数据，在此之后，您将需要检查返回的迭代器的值，以进行任何进一步的筛选/查找。

票数 2

EN

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/72604196

复制

相关文章

用“回车”键代替“Tab”键

编辑器加载中... //首先将窗体的 keypreview 的属性设为 true private void 窗体_KeyPress(object sender, KeyPressEventArgs e) { if ( e.KeyChar == (char)13 ) { this.SelectNextControl(this.ActiveControl, true, true, false, true); } } //或 private void Form1_KeyDown(object sende

跟着阿笨一起玩NET

2018/09/18

2.5K0

卡夫卡入门

kafka 编程算法缓存数据结构 api

1.Kafka独特设计在什么地方？ 2.Kafka如何搭建及创建topic、发送消息、消费消息？ 3.如何书写Kafka程序？ 4.数据传输的事务定义有哪三种？ 5.Kafka判断一个节点是否活着有哪两个条件？ 6.producer是否直接将数据发送到broker的leader(主节点)？ 7.Kafa consumer是否可以消费指定分区消息？ 8.Kafka消息是采用Pull模式，还是Push模式？ 9.Procuder API有哪两种？ 10.Kafka存储在硬盘上的消息格式是什么？一、基本概念介绍 Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能，但具有自己独特的设计。这个独特的设计是什么样的呢？首先让我们看几个基本的消息系统术语： Kafka将消息以topic为单位进行归纳。将向Kafka topic发布消息的程序成为producers. 将预订topics并消费消息的程序成为consumer. Kafka以集群的方式运行，可以由一个或多个服务组成，每个服务叫做一个broker. producers通过网络将消息发送到Kafka集群，集群向消费者提供消息，如下图所示： <ignore_js_op>

步履不停凡

2019/09/11

8380

不使用除法的“除法”

题目：给定一个字符串 s 和一些长度相同的单词 words。找出 s 中恰好可以由 words 中所有单词串联形成的子串的起始位置。

MickyInvQ

2021/03/02

1.5K0

不使用除法的“除法”

给定一个字符串 s 和一些长度相同的单词 words。找出 s 中恰好可以由 words 中所有单词串联形成的子串的起始位置。

MickyInvQ

2021/02/09

1.4K0

python的常见矩阵除法_Python矩阵除法

我有一个关于按元素划分矩阵的问题，我的意思是我想要第一个矩阵的元素[I，j]除以第二个矩阵(Q)的元素[I，j]。在

全栈程序员站长

2022/07/02

3.2K0

BigDecimal 除法

https java 网络安全

divide(BigDecimal divisor, int scale, int roundingMode)

全栈程序员站长

2022/07/02

2.4K0

BigDecimal除法问题

https java 网络安全

BigDecimal做除法时，尽量使用divide(BigDecimal divisor, int scale, int roundingMode),这个方法

全栈程序员站长

2022/07/02

1.2K0

truncate 二进制效率

给定两个整数 a 和 b ，求它们的除法的商 a/b ，要求不得使用乘号 '*'、除号 '/' 以及求余符号 '%' 。

Johns

2022/09/28

2.8K0

Python3除法之真除法、截断除法和下取整对比

math python3 数学

在Python3中，数学运算中的除法被分为两种，分别是“真除法”，即无论任何类型相除的结果都会保留小数点，和我们实际的数学运算结果一致，而“截断除法”，则是无论任何类型相除的结果都会省略结果的小数部分，剩下最小的能整除的整数部分。以下是两种除法的基本形式：

一墨编程学习

2019/06/15

2.4K0

java简单的除法运算_Java除法运算的陷阱[通俗易懂]

c++数据结构 https java 网络安全

对于Double、Float，API都提供了几个有用的判断方法，要注意运用其写出安全的代码：

全栈程序员站长

2022/09/05

1.7K0

java怎样解决除法精度_java 除法精度问题

python java 编程算法

public static void main(String[] args){

全栈程序员站长

2022/09/06

2K0

python 除法和乘方

1.除法在做数值计算的时候，经常能遇到2/3这种情况。为啦能得到0.667这样的小数通常需要使用float()来实现。当需要小数的地方多了的时候，就会是代码的可读性下降。可以在代码开头添加from __future__ import division实现。但是导入这个语句之后，当我们只要整数部分，就只能得到小数。可以使用//的实现这样的目的。 from __future__ import division print 2/3 #正常除法 print 2//3 #只要整数部分 prin

py3study

2020/01/07

2.6K0

[零基础学python]啰嗦的除法

python 编程算法

除法啰嗦的，不仅是python。整数除以整数看官请在启动idle之后，练习下面的运算： >>> 2/5 0 >>> 2.0/5 0.4 >>> 2/5.0 0.4 >>> 2.0/5.0 0.4

py3study

2020/01/05

1.8K0

BigDecimal的除法

java https 网络安全

发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/147892.html原文链接：https://javaforall.cn

全栈程序员站长

2022/07/02

1.9K0

matlab 矩阵除法

https java 网络安全

Matlab提供了两种除法运算：左除（/）和右除（/）。一般情况下，x=a/b是方程a*x =b的解，而x=b/a是方程x*a=b的解。例：a=[1 2 3; 4 2 6; 7 4 9] b=[4; 1; 2]; x=a/b 则显示：x= -1.5000 2.0000 0.5000 如果a为非奇异矩阵，则a/b和b/a可通过a的逆矩阵与b阵得到： a/b = inv(a)*b b/a = b*inv(a)

全栈程序员站长

2022/09/07

1.6K0

Kafka体系结构：日志压缩

这篇文章是从我们介绍Kafka 体系结构的一系列文章中获得的启发，包括Kafka topic架构，Kafka生产者架构，Kafka消费者架构和Kafka生态系统架构。

用户1902519

2018/05/31

2.9K1

基于迭代单元的除法器基于迭代单元的除法器

编程算法数据处理 fpga

基于迭代单元的除法器迭代单元数字信号处理中，有大量的算法是基于迭代算法，即下一次的运算需要上一次运算的结果，将运算部分固化为迭代单元可以将数据处理和流程控制区分，更容易做出时序和面积优化更好的硬件

月见樽

2018/04/27

1.9K0

基于迭代单元的除法器基于迭代单元的除法器

除法运算符

对于表中所列值以外的其他值组合，将"Expression.Error"引发带有原因代码的错误。以下各节介绍了每种组合。

冬夜先生

2022/01/05

1.9K0

map合并，相同键对应的值相加

最近在做统计钱的计算时遇到的一个需求，需要将一个大类别下的每一种钱进行特定的运算然后获得六年的钱，最后将这些钱按照年份进行汇总，获得总得大类型的六年的钱，在这个过程中采用了这种方法，每次算得钱放在map中，然后将map进行合并，写篇随笔mark下。

河岸飞流

2019/08/09

4K0

Python如何修改字典键所对应值

字典中有成对出现的键和值，但是字典中的键值对不是都能修改的，只有值才能修改，我们可以把字典中的键理解为列表下标，一个列表的下标永远是从0开始依次递增1的，是无法修改的。

python自学网

2021/12/02

4.9K0

Python如何修改字典键所对应值

相似问题

浮点除法代替整数除法

10

在Python中整数除法代替常规除法

27

用减法代替除法:如何用减法逼近除法

29

地理编码器用英语代替本地语言

314

如何用副翼代替卡夫卡

14

添加站长进交流群

领取专属 10元无门槛券

AI混元助手 在线答疑

关注 腾讯云开发者公众号

洞察 腾讯核心技术

剖析业界实践案例