现在，我正在做一个使用Kafka Streams来处理消息的项目。我们的消息由两个标识符组成，一个是用户的标识符，第二个是用户所属的消息列表的标识符。这个应用程序的故事是，一个客户端想要通过我的应用程序向他们的用户列表发送推送消息。因此，客户端在向用户发送推送消息之前从外部源加载用户列表，然后开始发送。但是客户端也希望在他想要的时候停止正在进行的发送。
我的问题在这一点上出现了。我想停止发送推送消息，而不是通过kafka的流api消费所有消息。
浏览 0提问于2017-12-15得票数 1
我使用的是Kafka Stream API。当我启动我的应用程序时，有时会有一个间隙，我想从一个特定的偏移量开始消费。最早或最晚的不是我想要的。
浏览 25提问于2020-05-02得票数 2
回答已采纳
1回答
团队，Kafka-streams应用部署应该遵循什么策略？为了克服这种情况，我们尝试了设置kafka-consumer/XXX/kafka-1.0.0/bin/kafka-consumer-groups.sh
浏览 0提问于2018-05-24得票数 0
我在读关于Kafka Stream - Elastic Scaling特性的文章。
意味着Kafka Stream可以将任务移交给其他实例，任务状态将使用changelog创建。是和Consumer Group的工作原理一样，还是因为Kafka Stream实例并不完全是consumer Group中的Consumer而导致机制不同？
浏览 0提问于2019-11-14得票数 0
2回答
有没有可能有一个Kafka Streams应用程序，运行一个主题中的所有数据，然后退出？
例如，我根据日期将数据生成主题。使用者被cron踢开，遍历所有可用的数据，然后..做什么？
浏览 26提问于2016-08-20得票数 8
回答已采纳
这是关于升级生产中的现有代码库，这些代码库使用来自kafka-clients，kafka-streams，spring-kafka 2.4.0到2.6.x的窗口，并将spring-boot-starter-parent2.2.2.RELEASE升级到2.3.x，因为2.2与kafka-streams 2.6不兼容。streams code}
现在，将kafka streams，kaf
浏览 20提问于2021-05-15得票数 2
(根据我对Kafka streams的记忆，很久以前)我相信Kafka Streams处理器总是运行在运行Kafka本身的JVM上。在这种情况下，这基本上是不可能的。
浏览 0提问于2018-02-16得票数 13
回答已采纳
我编写了Kafka流应用程序，我想将它部署到Kafka集群上。，我构建了一个jar文件并使用以下命令运行它：它运行正常，但作业运行在我在命令上运行的机器上！那么，我的问题是如何在Kafka集群上提交kaf
浏览 1提问于2017-12-01得票数 5
回答已采纳
KeyValue<>(key, outputMessage); } cloud: kafka: binder: - ${NX_KAFKA_SERVERS}
bindings
浏览 6提问于2020-10-09得票数 0
回答已采纳
如果我有一个Kafka流应用程序无法发布到主题(因为主题不存在)，它是提交消费者偏移量并继续，还是在相同的消息上循环，直到它可以解析输出主题？根据我的观察，这个应用程序只是打印了一个错误，并且运行正常。我这样问是因为我们不想在健康检查正常的情况下结束(应用程序正在运行，同时将错误打印到日志)，而我们只是丢弃了大量的Kafka消息。
浏览 13提问于2019-05-31得票数 1
回答已采纳
1回答
我正在创建一个kafka流来将信息从一个应用程序复制到另一个应用程序，当我不需要发送数据或可能导致问题时，目标api会有一些维护窗口。
浏览 0提问于2020-06-29得票数 0
相反，将引发下面的异常并停止应用程序。$withKey$2(AbstractStream.java:111) at org.apache.kafka.<
浏览 12提问于2022-08-11得票数 0
回答已采纳
我试图理解Kafka Streams API是如何与Schema Registry一起工作的。我知道在设置应用程序时必须指定Schema Registry URL，但我无法理解如果不指定主题名称或ID，应用程序如何从注册表检索正确的模式。
它使用主题名称检索模式？
浏览 2提问于2019-11-25得票数 2
1回答
org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:400) ~[kafka-streams-:475) ~[kafka-streams-2.5.1.jar:na]
at org.apache.kafka.streams.processor.internals.TaskManager.process(StreamThread.java:6
浏览 3提问于2020-12-03得票数 0
回答已采纳
2回答
我们在kotlin中有一个org.apache.kafka:kafka-streams:3.2.3应用程序，并从org.apache.kafka:kafka-streams:3.3.1切换到KStreamsat org.apache.kafka.streams.KafkaStreams.at org.apache.kafka.streams.KafkaStreams.at org.apache.<e
浏览 21提问于2022-10-14得票数 5
我正在一个服务中运行多种kafka流实例。我希望动态地调整num.stream.threads配置，以便在程序运行时控制每个实例的优先级。
我没有在KafkaStream类上找到相关的方法。
浏览 2提问于2019-01-04得票数 1
回答已采纳
我有一个卡夫卡流应用程序版本- 0.11，它从几个主题中获取数据，并将数据加入到另一个主题中。每当我把卡夫卡经纪人打倒，它就会抛到异常之下： at org.apache.kafka.streams.processor.internals.StandbyTask.但是每次我们启动
浏览 4提问于2017-09-13得票数 0
当我运行应用程序并向这两个主题发送消息时，join将按预期的方式工作。; } at org.apache.kafka.streams.state.internals.
浏览 2提问于2020-06-06得票数 0
回答已采纳
();执行几分钟后，应用程序抛出下面的异常manager ... 13 more
我试图清除/tmp/
浏览 17提问于2017-02-22得票数 7
回答已采纳
我试图将目前用Java代码编写的spring应用程序的配置具体化。到目前为止，看来我应该把我所有的配置都放到KafkaStreamsConfiguration类型的bean中，以便配置我的kafka-streams应用程序。spring.kafka.streams.replication-factor=1spring.kafka</e
浏览 1提问于2019-06-13得票数 3
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
