腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
目录中每次添加新文件时,如何触发
Kafka
生产者?
scala
、
triggers
、
apache-kafka
、
producer-consumer
我有一个
Kafka
流媒体制作器(在scala中),它从目录中的所有文件中提取数据,并将其内容发布到一个主题中。然后,该内容由消费者处理。现在我正在通过shell手动执行生产者和消费者(都是在scala中),但是我如何才能触发
Kafka
生产者和消费者在每次将文件添加到生产者从中检索文件的目录时自动执行呢?任何帮助都将不胜感激!
浏览 1
提问于2018-03-18
得票数 1
1
回答
Apache
Kafka
:对消费者组进行程序化
监控
python
、
apache-kafka
、
kafka-consumer-api
、
confluent-platform
、
kafka-python
我想从Python应用程序中
监控
我的
Kafka
集群中的消费者组(基于
Kafka
的组,而不是ZK) (我愿意使用
Kafka
-python库和confluent
Kafka
客户端中的任何一个)。confluent
Kafka
admin
API
似乎没有Python选项来实现这一点。Burrow似乎是一种选择。但这将是一个额外的服务来设置和
监控
。 任何替代方法也是受欢迎的。
浏览 2
提问于2018-08-13
得票数 0
3
回答
如何构建高效的
Kafka
broker健康检查?
java
、
scala
、
apache-kafka
在我的应用程序中,我将对我的
Kafka
集群执行某种健康检查。目前,我创建了一个TopicMetadataRequest来检测死掉的代理: // this will fail if
Kafka
is unavailable consumer.send有没有更好的方法来检查
kafka
经纪人?我需要的是像true/false指示器这样简单的东西。
浏览 1
提问于2015-07-17
得票数 10
回答已采纳
2
回答
在
Kafka
集群中按主题查找磁盘使用情况
apache-kafka
是否有
Kafka
监控
指标、Java
API
或JMX bean来获取
Kafka
集群中每个主题的磁盘使用情况? 有没有办法确定集群的总磁盘使用量,包括所有主题/分区/副本?
浏览 58
提问于2020-09-10
得票数 0
回答已采纳
2
回答
监控
Kafka
Spout
performance
、
apache-storm
、
apache-kafka
我正在尝试为我的项目
监控
Kafka
spout的性能。我使用的是apache-storm-0.9.2-孵化版本中包含的KafkaSpout。可以使用
kafka
偏移量
监控
工具
监控
kafka
spout的吞吐量吗?有没有其他更好的方法来
监控
喷嘴? 谢谢,Palak Shah
浏览 2
提问于2014-10-09
得票数 0
2
回答
如何在分配了特定主题分区的
Kafka
中检查消费者的滞后?
apache-kafka
、
kafka-consumer-api
我正在使用
Kafka
- 0.10.0.1运行sh
kafka
- .I -class.sh
kafka
.admin.ConsumerGroupCommand -new- consumer -describe-bootstrap-server
浏览 4
提问于2018-01-17
得票数 1
1
回答
GenericJMXConfMBean:没有MBean匹配ObjectName
kafka
.network:type=RequestMetrics,name=RequestsPerSec,request
apache-kafka
、
jmx
、
collectd
我正在从事一个项目,在这个项目中,我试图使用'
kafka
.network:type=RequestMetrics,文档中定义的mbean度量request={Produce|FetchConsumer|
kafka
-run-class
kafka
.tools.JmxTool -jmx-url
kafka
.tools.JmxTool--对象名称
kafka
.network:type=RequestMetrics我使用的
kafka
版本是2.1
浏览 12
提问于2020-06-24
得票数 1
3
回答
使用开源工具
监控
Kafka
apache-kafka
有没有开源工具来
监控
融合的
Kafka
?大多数可用的开源工具都是特定于Apache
Kafka
的,但不是针对Confluent
Kafka
的。 我们希望至少
监控
连接器、流和集群的运行状况
浏览 3
提问于2017-07-04
得票数 0
2
回答
Spring netflix eureka,zuul vs Spring cloud数据流
spring
、
microservices
、
spring-cloud-netflix
、
spring-cloud-stream
我是微服务领域的新手。想知道什么时候使用Spring eureka,zuul vs spring数据流。微服务部署的技术选择应该是什么?
浏览 1
提问于2017-06-01
得票数 4
2
回答
在Python中
监控
Kafka
python
、
jmx
、
apache-kafka
、
codahale-metrics
我正在采用
Kafka
,并试图了解如何
监控
它(例如,它是否耗尽了用于日志存储的内存)。我看到它使用Yammer Metrics并通过JMX公开它们-这对Java领域的人来说显然是有意义的。有没有可以构建的HTTP
API
?或者是任何一种相对结构化的输出?
浏览 7
提问于2015-03-18
得票数 2
1
回答
如何使用INSTANA监视和管理Apache
Kafka
和Zookeeper集群
apache-kafka
、
apm
、
instana
我已经在生产中搭建了一个
Kafka
& Zookeeper集群。我需要设置INSTANA APM工具来
监控
和管理生产
Kafka
& Zookeeper集群。有没有人曾经使用INSTANA来
监控
Kafka
。请分享您对此的看法。
浏览 33
提问于2019-04-10
得票数 3
1
回答
如何获取运行在ibm云上的中间件服务的可用性状态?
apache-kafka
、
ibm-cloud
、
ibm-mq
、
apiconnect
IBM内部
监控
云上提供的服务,但不知何故,我需要获得中间件服务的状态,如
kafka
,
API
Connect等。它将帮助我自动化一些服务停止/不可访问的事情。
浏览 13
提问于2019-10-14
得票数 0
回答已采纳
0
回答
如何使用nagios
监控
apache
kafka
?
apache-kafka
、
monitoring
、
metrics
、
nagios
有没有办法使用nagios
监控
我的
kafka
集群?有没有需要检查的工作插件、
api
或其他东西:代理状态、分区状态、内存状态、当前偏移量以及集群中所有有价值的指标?
浏览 12
提问于2017-12-12
得票数 1
1
回答
如何从消费者群体的卡夫卡话题中找到消费数据的起始时间
java
、
apache-kafka
、
kafka-consumer-api
有什么
API
可以用来找出消费者群体从卡夫卡话题开始消费的起始时间吗? 我使用的是卡夫卡0.11版
浏览 3
提问于2017-12-07
得票数 0
回答已采纳
1
回答
Kafka
心跳线程阻塞
java
、
apache-kafka
、
apache-camel
我们有一个WebSocket服务器,它为每个WebSocket客户端创建一个单独的消费者组,这样每个WebSocket用户就可以相互独立地接收来自
Kafka
主题的更新。我们使用camel
API
来创建
Kafka
消费者(组),它使用了
Kafka
原生Java
API
,所以这与Camel没有任何关系,但提到camel只是一个FYI。通过使用JMX和JMC
监控
,我们发现
Kafka
心跳线程被阻塞,并且对于每次新的WebSocket客户端加入时创建的每个新消费者组,被阻塞线程的数量
浏览 1
提问于2018-11-06
得票数 1
2
回答
获取关于
Kafka
connect集群的信息
apache-kafka
、
apache-kafka-connect
我目前正在让
Kafka
使用相同的group.id连接两个节点的集群 当使用curl /connectors时,我可以获得我创建的连接器的列表,但我看不到关于活动节点的信息,健康检查...
浏览 25
提问于2019-02-05
得票数 1
1
回答
如何查询
Kafka
消息的处理时间?
spring-boot
、
apache-kafka
、
spring-kafka
、
prometheus-alertmanager
我有一个运行
Kafka
消费者的应用程序,并希望
监控
从主题消耗的每条消息的处理时间。该应用程序是一个Spring引导应用程序,并使用micrometre注册表将
Kafka
消费者指标公开给Spring Actuator Prometheus端点。我可以使用
kafka
_consumer_commit_latency_avg_seconds或
kafka
_consumer_commit_latency_max_seconds来
监控
或报警吗?
浏览 1
提问于2020-09-21
得票数 0
3
回答
有没有Apache
Kafka
消费者滞后检查器?
apache-kafka
我的
Kafka
用户将他们的偏移量提交给
Kafka
(而不是Zookeeper),所以我不能使用。所以我想知道除了上面两个之外,有没有Apache
Kafka
消费者滞后检查器?我用谷歌搜索了一下,但没有找到多少有用的信息。提前感谢!
浏览 0
提问于2015-11-24
得票数 3
2
回答
在boot2docker中运行卡夫卡时使用JMX的卡夫卡
监控
docker
、
boot2docker
、
apache-kafka
我试图让JMX
监控
来
监控
一个测试
kafka
实例。 我有卡夫卡(千斤顶/卡夫卡)运行在码头通过boot2docker,但我不能得到正确配置的JMX
监控
。我已经做了大量的故障排除,我知道
kafka
实例正在正常运行(消费者和生产者都在工作)。配置注意事项:我连接到192.168.59.103 (运行'boot2docker ip‘时发现的virtualbox ip),ches/boot2docker/
kafka
实例使用端口7203作为JMX_PORT(
浏览 1
提问于2015-07-01
得票数 2
回答已采纳
5
回答
Java中有什么
Kafka
监控
API
吗?
java
、
message-queue
、
apache-kafka
、
broker
我正在尝试编写一个Java代码,以获得消费者补偿和我们的
kafka
集群的滞后。是否有Java来获取这些信息?
浏览 12
提问于2015-09-08
得票数 3
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka监控系统Kafka Eagle剖析
Kafka消费者API
Kafka监控之雅虎kafka-manager
Flume-Kafka-SparkStreaming实战3-kafka监控
日记:Mac上kafka单机搭建和监控工具kafka eagle
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券