KTable 数据 - 字节打印
Posted
技术标签:
【中文标题】KTable 数据 - 字节打印【英文标题】:KTable data - Bytes printing 【发布时间】:2021-10-01 12:50:52 【问题描述】:我在 Kafka 中有一个 KTable,当我调试时,我会以字节为单位获取数据。
如果我想要它在 String 中,我应该怎么做?我也附上了一个sn-p。
【问题讨论】:
【参考方案1】:LinkedHashMap 的key
是一个字符串。如果您在调试器中展开任何字符串,您将看到它的字节表示。
突出显示的“值”不是地图键的值,而是屏幕截图底部的值字段。
另外,您正在扩展拓扑构建器,这不是表中的实际值。如果想看表中的数据,table.toStream().print()
【讨论】:
【参考方案2】:类似:
public static String byteArrayToHexString(byte[] rawBytes)
final String HEXCHARS = "0123456789abcdef";
StringBuilder sb = new StringBuilder(rawBytes.length * 2);
for (int i = 0; i < rawBytes.length; i++)
int ix = (rawBytes[i] >> 4) & 0xF;
sb.append(HEXCHARS.charAt(ix));
ix = rawBytes[i] & 0xF;
sb.append(HEXCHARS.charAt(ix));
return sb.toString();
【讨论】:
谢谢,但我想我可以将它转换为物化视图本身。你知道吗? 我不抱歉。只是想我会发布一个通用解决方案以上是关于KTable 数据 - 字节打印的主要内容,如果未能解决你的问题,请参考以下文章
可以将 Kafka Streams 配置为等待 KTable 加载吗?
KSQL KTabke+KTable Join重复结果异常。