apache-kafka-streams
-
不满意的LinkError: /tmp/snappy-1.1.4-libsnappyjava.so 加载共享库ld-linux-x86-64.so.2时出错:没有这样的文件或目录 我正在尝试在 kubernetes 中运行 Kafka Streams 应用程序。当我启动 pod 时,我得到以下异常:
-
处理 Kafka 流中的异常 已经经历了多个帖子,但其中大多数是相关的处理坏消息,而不是处理它们时的异常处理。 我想知道如何处理流应用程序收到的消息,并且在处理消息时出现异常?例外情况可能是由于多种原因
-
是否可以使用 Kafka Streams 访问消息标头? 通过在 Kafka 0.11 中的记录(,在使用 Kafka Streams 处理主题时,是否可以获取这些标头?当调用像 on a 这样的方法时,它会提供 记录的 和 的参数,但我无法看到访问 .如果我们能越过s就好了。
-
Kafka 流用于添加全局存储的用例 在 kafka 流中定义拓扑时,可以添加全局状态存储。它将需要一个源主题以及一个 .处理器接收记录,并可以在将它们添加到存储之前从理论上转换它们。但在还原的情况下,记录直接从源主题(c
-
将 Kafka 流输入打印到控制台?示例数据问题法典 我一直在查看很多Kafka文档,了解我正在开发的Java应用程序。我已经尝试过进入Java 8中引入的lambda语法,但我在这方面有点粗略,并且不太相信它应该是我迄今为止使用的。 我有一个Kafka / Zookee
-
-
将 Kafka 输入流动态连接到多个输出流 Kafka Streams中是否内置了允许将单个输入流动态连接到多个输出流的功能? 允许基于真/假谓词进行分支,但这不是我想要的。我希望每个传入的日志确定它将在运行时流式传输到的主题,例如,
标签