1回答
我想截获kafka的投票请求，以便记录一些信息，如响应时间，可用消息数量。我使用了springAOP，但没有成功。我已经在使用@KafkaListener逐条消费消息，但我还想跟踪投票请求。
浏览 50提问于2021-01-21得票数 0
回答已采纳
从那时起，消费者就显示了100%的cpu使用率。当经纪人上升时，使用率大大下降了(不到10%)。，我很好奇，为什么经纪人倒闭时的使用率是100% (或接近100%)？我在日志里什么都没看到。Kafka broker/服务器: 0.8.2.1
Kafka高级api: 0.8.2.0
浏览 0提问于2015-10-01得票数 5
kafka消费者是否可以暂停一段确定的时间间隔，比如2分钟，并在给定的时间间隔结束后自动恢复。或者，我们可以提供暂停命令的时间窗口吗？
浏览 5提问于2021-06-17得票数 0
spark版本是2.2.0伪代码：从kafka阅读data2，10分钟窗口和5分钟幻灯片持续时间执行一些agg并写入mysqlinternals.AbstractCoordinator: [Consumer clientId=consumer-3, groupId=dashboard] (Re-)joining group
在窗口时间戳，只做kafka
浏览 62提问于2019-07-19得票数 0
回答已采纳
我有一个基于rest的应用程序部署在服务器(Tomcat)，每个请求来服务器它需要1秒的时间来服务，现在我有一个问题，有时服务器收到更多的请求比它能够服务，使服务器没有响应。现在我在想，我是否可以将请求存储在一个队列中，这样服务器就可以拉取请求并为该请求提供服务，并处理挑选时间问题。
现在我在想，Kafka对此是否有帮助，如果是，我可以从哪里开始。
浏览 0提问于2017-04-07得票数 4
我考虑使用Kafka，如下所示：
[Kafka] ---????won服务器(如Jetty)，http请求将被“保持打开”，但不会被阻塞。可以以请求/响应的方式使用
浏览 0提问于2016-03-07得票数 1
我们正在尝试优化我们的python应用程序，它通过confluent python kafka客户端生成消息到kafka主题，使用confluent控制中心，我们可以检查特定的消息是否传递到kafka主题，所以现在的问题是，我们应该在producing之后使用poll()函数，因为交付回调现在被删除了，如果我们在1秒内产生100K消息，它是否会导致更好的吞吐量。producer.produce( topic=topicName, value=msg, key=msg_key)
producer.poll(
浏览 18提问于2020-11-10得票数 0
据我所知，kafka消费者只能使用API轮询()从代理中提取消息，但是我们知道我们也可以使用kafka高/low级别的使用者API从代理获取消息，那么kafka高/low级消费者API和API轮询()之间的关系是什么高/low级别的使用者API调用轮询()内部？
浏览 1提问于2017-05-15得票数 0
回答已采纳
我使用Spring Boot 2.0.7和Spring-Kafka来创建请求/应答模式。基本上，前端UI向API发出请求，API将消息放到请求Kafka队列中，消息由后端进程处理，完成后将消息放到应答队列中。
我想提供的前端用户界面的api，等待，直到响应准备就绪。我是Spring-Kafka的新手。它允许我创建一个轮询API吗？如果是这样的话，任何示例代码都将非常感谢。
浏览 1提问于2018-12-08得票数 0
但是，当我测试KafkaConsumer进行轮询时，代理会发出错误消息。2016-03-18 13:44:19,129错误关闭/172.26.132.149套接字(kafka.network.Processor) kafka.common.KafkaException:错误请求类型:353) at kafka.network.Processor.run(SocketServer.scala:245)
使用者测试代码如下所示。= %d, key = %s, value =
浏览 0提问于2016-03-18得票数 1
我在服务器启动时启动Kafka consumer。如果Kafka集群长时间(几个小时)宕机，对消费者会有什么影响？Kafka再次上线后会收到消息吗？
浏览 46提问于2019-12-12得票数 0
1回答
我正在寻找kafka来实现一个低延迟的消息队列，并且我一直在阅读关于消费者长轮询的文章。但是，没有关于如何实际使用长轮询的示例，或者需要设置哪些选项才能启用它。如何使用kafka java api启用长轮询？
浏览 0提问于2013-10-25得票数 12
回答已采纳
此外，我需要请求第三方服务，这将是缓慢和不稳定的。所以我想出了一个想法，让它成为事件驱动的，并使用apache kafka。WebClient_X--request--->LoadBalancer--forward-->A-Service_1--request--->ThirdPartyService这次又是什么？- A-Se
浏览 2提问于2016-09-14得票数 0
在spring-boot (版本2.1.4)应用程序中，需要将apache-kafka迁移到spring-kafka。当前的kafka使用者做: 1)在应用程序启动时初始化的apache 2)它有"0“主题分区集3)使用KafkaConsumer kafkaConsumer将数据轮询到ConsumerRecord 4)应用程序自己的重试机制等待并再次轮询直到max_retry 遗留代码如下所示： while (!spring kafka注解
浏览 21提问于2019-04-15得票数 0
2回答
我正在使用Kafka实现一个定制的Source，它可以用来轮询REST- API，并将JSON响应转换成Kafka主题。现在，我想知道如何实现SourceTask的轮询间隔，JDBC如何提供轮询间隔。在某个地方，我必须设置线程睡觉，但我必须在哪里这样做呢？
浏览 5提问于2017-04-07得票数 5
回答已采纳
我是Kafka Java API的新手，我正在使用来自特定Kafka主题的记录。我想知道这是不是两者唯一的区别？
浏览 1提问于2018-12-27得票数 17
回答已采纳
4回答
我已经思考了现实世界卡夫卡应用程序的基础上，一般的请求响应消息，更具体地说，如何链接卡夫卡请求消息和它的响应消息。
我考虑使用生成的UUID作为请求消息密钥，并使用该请求UUID作为关联的响应消息键。Kafka客户端生成一个随机的UUID，并发送一个Kafka请求消息。2)。服务器将使用此请求消息提取&存储请求UUID值3)。使用消息有效负载完成业务流程。
浏览 3提问于2016-02-21得票数 29
回答已采纳
我正在开发一个接受用户请求的REST服务。每个用户请求都代表着繁重的计算工作。我不希望计算工作阻塞REST服务。我的设计是将用户请求包装为任务(具有唯一的任务id)并推送到Kafka。后台工作人员订阅Kafka并处理任何传入的任务。REST服务将任务保存到数据库中，将任务id推送到Kafka，然后立即返回任务id。用户使用任务id轮询任务状态。
这个设计很好。但我仍然不知道如何处理一种情况:如果在将任务保存到数据库之后，但在将任务id推送到Ka
浏览 2提问于2018-02-08得票数 0
使用CNCF的Strimzi Kafka Bridge，我创建了一个小API，它可以使用HTTP/1.1协议与Kafka服务器交互。这对于请求-响应场景来说是很好的。但是，我的要求是在收到Kafka主题上的事件时，立即将它们流式传输到订阅客户端(通过Strimzi桥)，最好是通过长时间的HTTP连接(根据我的理解)。不断轮询桥上的消息，然后空手而归，这是对客户端资源的浪费。我希望Kafka服务器将这些事件直接流到客户端。 我对SSE、Webs
浏览 29提问于2019-10-05得票数 2
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
