blocks|key|1738769|text|任何抑制中间结果的替代办法都是有帮助的。|type|blockquote|depth|inlineStyleRanges|entityRanges|data|1738770|在之前版本的Kafka流中，没有提供与最近引入的抑制特性相同行为的等效功能。|unstyled|offset|length|1738771|您能得到的最接近的是配置您的Kafka流应用程序的记录缓存(如cache.max.bytes.buffering)和commit.interval.ms，以减少您将看到的“中间”更新的数量。但这不会完全删除任何此类更新，不像新的抑制功能。|style|CODE|1738772|entityMap|0|LINK|mutability|MUTABLE|url|https://www.confluent.io/blog/kafka-streams-take-on-watermarks-and-triggers/|1|https://kafka.apache.org/10/documentation/streams/developer-guide/config-streams.html^0|0|J|9|0|0|V|P|1M|I|A|E|1|0^^$0|@$1|2|3|4|5|6|7|U|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|V|8|@]|9|@$E|W|F|X|1|Y]]|A|$]]|$1|G|3|H|5|D|7|Z|8|@$E|10|F|11|I|J]|$E|12|F|13|I|J]]|9|@$E|14|F|15|1|16]]|A|$]]|$1|K|3|-4|5|D|7|17|8|@]|9|@]|A|$]]]|L|$M|$5|N|O|P|A|$Q|R]]|S|$5|N|O|P|A|$Q|T]]]]

<blockquote>
 Any alternatives for suppressing the intermediate results would be helpful.
</blockquote>

There is no equivalent functionality available in prior versions of Kafka Streams that give you the same behavior as the <a href="https://www.confluent.io/blog/kafka-streams-take-on-watermarks-and-triggers/" rel="nofollow noreferrer">recently introduced Suppress feature</a>.

The closest you can get is to <a href="https://kafka.apache.org/10/documentation/streams/developer-guide/config-streams.html" rel="nofollow noreferrer">configure your Kafka Streams application</a>'s record caches (settings like <code>cache.max.bytes.buffering</code>) and the <code>commit.interval.ms</code> to reduce the number of "intermediate" updates you will be seeing. But this will not fully remove any such updates unlike the new Suppress feature.

blocks|key|1949575|text|您可以覆盖卡夫卡客户端和卡夫卡流版本，如Apache+Kafka春季附录参考手册中所述。|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|1949576|如果您没有在测试中使用嵌入式kafka代理，您只需要覆盖kafka客户端和流。|1949577|<dependency>
++++<groupId>org.apache.kafka</groupId>
++++<artifactId>kafka-clients</artifactId>
++++<version>2.1.1</version>
</dependency>

<dependency>
++++<groupId>org.apache.kafka</groupId>
++++<artifactId>kafka-streams</artifactId>
++++<version>2.1.1</version>
</dependency>|code-block|syntax|javascript|1949578|entityMap|0|LINK|mutability|MUTABLE|url|https://docs.spring.io/spring-kafka/docs/2.2.11.RELEASE/reference/html/#deps-for-21x^0|K|G|0|0|0|0^^$0|@$1|2|3|4|5|6|7|S|8|@]|9|@$A|T|B|U|1|V]]|C|$]]|$1|D|3|E|5|6|7|W|8|@]|9|@]|C|$]]|$1|F|3|G|5|H|7|X|8|@]|9|@]|C|$I|J]]|$1|K|3|-4|5|6|7|Y|8|@]|9|@]|C|$]]]|L|$M|$5|N|O|P|C|$Q|R]]]]

You can override the kafka-clients and kafka-streams versions, as described in the <a href="https://docs.spring.io/spring-kafka/docs/2.2.11.RELEASE/reference/html/#deps-for-21x" rel="nofollow noreferrer">appendix to the Spring for Apache Kafka</a> reference manual.

If you are not using the embedded kafka broker in tests, you just need to override the kafka clients and streams.

<pre class="lang-xml prettyprint-override"><code>&lt;dependency&gt;
 &lt;groupId&gt;org.apache.kafka&lt;/groupId&gt;
 &lt;artifactId&gt;kafka-clients&lt;/artifactId&gt;
 &lt;version&gt;2.1.1&lt;/version&gt;
&lt;/dependency&gt;

&lt;dependency&gt;
 &lt;groupId&gt;org.apache.kafka&lt;/groupId&gt;
 &lt;artifactId&gt;kafka-streams&lt;/artifactId&gt;
 &lt;version&gt;2.1.1&lt;/version&gt;
&lt;/dependency&gt;
</code></pre>

I am using Kafka-streams-binder in my Spring Cloud project. The Kafka stream application uses sliding window of 6 minutes to aggregate the results and analyze patter. But the problem is that the aggregation operation is generating duplicate results.

I want to suppress the intermediate results and publish only after the window ends in the application. This can be achieved by Kafka .supress() operation in Kafka 2.1.1. But the Spring Cloud version does not have the latest kafka to use the capability.

Dependencies used by Project

<blockquote>
<pre><code>&lt;spring-boot.version&gt;2.1.9.RELEASE&lt;/spring-boot.version&gt;
&lt;spring-cloud.version&gt;Greenwich.SR3&lt;/spring-cloud.version&gt;
</code></pre>
</blockquote>

Any alternatives for suppressing the intermediate results would be helpful.

How to supress windowed aggregation result in Spring Cloud Kafka Streams?

翻译质量差，导致语言生硬或混乱。

没有提供实际的解决方法或示例。

解答不清晰，无法理解或解决问题。

页面排版不美观，阅读体验差。

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

EdgeOne AI 安全实战专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云AI代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

功能1上新10个字符

功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符。

功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符。

功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符

功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符

功能4上新

文章&问答评论现已支持表情

全新交互，全新视觉，新增快捷键、悬浮工具栏、高亮块等功能并同时优化现有功能，全面提升创作效率和体验

社区富文本编辑器全新改版！诚邀体验～ 

精选全网热门MCP server，让你的AI更好用 🚀

💥开发者 MCP广场重磅上线！

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

社区新版编辑器体验调研

我在我的Spring项目中使用Kafka-streams-binder。Kafka流应用程序使用6分钟的滑动窗口对结果进行汇总和分析。但问题是聚合操作正在产生重复的结果。我想要抑制中间结果，并且只在应用程序的窗口结束后才发布。可以通过Kafka 2.1.1中的Kafka .supress()操作来实现。但是Spring版本没有最新的kafka使用这种功能。项目依赖项<spring-boot.ver

问如何抑制Spring流中窗口聚集的结果？
EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何抑制Spring流中窗口聚集的结果？EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何抑制Spring流中窗口聚集的结果？
EN