我有一个kafka主题，它通过设置cleanup.policy=compact启用了压缩。我的segment.bytes属性被设置为稍大的值（100mb），这样我的代理就可以很好地执行。
如果我有一个kafka streams应用程序，它使用主题作为globalktable，并且主题中的一个分区键有多个记录，那么该应用程序在globalktable中只接收一个记录，还是只有两个记录，直到压缩开始？
我有一个kafka主题，它通过设置cleanup.policy=compact启用了压缩。我的segment.bytes属性被设置为稍大的值（100mb），这样我的代理就可以很好地执行。
如果我有一个kafka streams应用程序，它使用主题作为globalktable，并且主题中的一个分区键有多个记录，那么该应用程序在globalktable中只接收一个记录，还是只有两个记录，直到压缩开始？
1条答案
按热度按时间z9zf31ra1#
globalktable中只有1条记录，因为默认情况下表是rocksdb状态存储，这是一个键值存储。因此，即使主题有多个键，表也只有一个键。