1回答
我知道Kafka API中可用于生产者指标的metric()方法。实际上，我正在尝试通过以下方式定期获取10k条记录、100k条记录等的指标： ? 我尝试用以下方式打印指标： for (Entry<MetricName, ?System.out.println(entry.getKey().name() + " : " + entry.getValue().metricValue());
} 但是这个方法返回的是生产者的
浏览 15提问于2019-05-08得票数 2
回答已采纳
1回答
缺少Kafka生产者jmx指标
、、、、
在没有经过devops团队太多调整的情况下，我们从kubernetes-service-endpoint exporter工作中获得了prometheus抓取的kafka消费者指标，以及一些生产者指标，但只针对kafka connect api，而不针对标准kafka生产者api。
浏览 1提问于2019-11-17得票数 1
我想使用kafka-console-producer cli工具向使用事务客户端的主题发送消息。我认为我的配置是正确的，但是当我运行cli工具时，我得到了以下异常：
java.lang.IllegalStateException: Cannot perform a 'send' before completing因此，看起来kafka控制台生产者，我相信它实例化了kafka.tools.ConsoleProducer类，要么没有调用initTrans
浏览 11提问于2021-04-02得票数 0
我正在使用Datadog从运行在我的本地主机上的Kafka收集指标。当我在我的Datadog代理上运行-info命令时，这是我为Kafka得到的错误。你知道这是什么原因吗？kafka - instance #kafka-localhost-9999 [ERROR]: 'Cannot connect to instance localhost:9999 java.io.IOException: Failed to retrieve
浏览 33提问于2016-08-27得票数 0
1回答
有没有办法使用Metrics java API从kafka.network:type=RequestMetrics,name=TotalTimeMs,request={Produce|FetchConsumer使用下面的代码，我能够获得生产者度量。 for (Entry<MetricName, ?System.out.println(entry.getKey().name() + " : " + entry.getValue().metricValue());
浏览 16提问于2019-05-12得票数 1
当我在nodejs消费者中使用m.message.value.toString('utf8')时，它会打印实际消息。但我需要在java Kafka消费中消费。我的问题是如何使用由nodejs生产者生成的java字符串格式的消息。
浏览 0提问于2019-03-11得票数 0
我们正在使用spring boot将我们的项目迁移到微服务。我有一个需求，我应该能够使用配置细节运行生产者和消费者，比如引导服务器和用户在运行时提供的键值serdes。在之前的项目中，我可以使用java Apache Kafka API来实现这一点，但我看不到使用spring-kafka API的任何方法，因为它只允许通过Spring java配置类或application.pro
浏览 14提问于2021-05-25得票数 1
我正在尝试使用sarama获取kafka生产者/消费者指标。但我找不到任何关于如何做到这一点的例子。有人能提供一个示例实现示例吗？
我使用以下代码来获取代理的指标。但是，为了获得生产者/消费者的指标，应该配置什么呢？我假设它不会是一样的。
浏览 11提问于2021-06-28得票数 0
我想使用ruby kafka客户端库来产生事件，但遇到了一个我不确定如何解决的问题。任何帮助都将不胜感激。 at java.nio.ByteBuffer.get(ByteBuffer.java:675) at
浏览 2提问于2013-02-08得票数 3
回答已采纳
Apache Beam和Apache Kafka在流处理方面有什么不同？我也在努力掌握技术和编程上的差异。
请通过您的经验报告来帮助我理解。
浏览 1提问于2018-06-15得票数 10
我在我的producer上看到了org.apache.kafka.common.errors.NotLeaderForPartitionException，据我所知，当producer试图向不是分区领导者的代理产生消息时
浏览 2提问于2020-08-17得票数 0
1回答
我正在尝试在不使用Confluent Control Center的情况下执行此操作，因为我没有许可证。我可以使用dcos task metrics details <broker-id>查看Kafka Broker指标，并且可以看到所有这些指标都已经在我的DCOS Prometheus实例上公开了。然而，我在Prometheus上看不到任何消费者/生产者指标，尽管在dcos上有一些生产者/消费者任务。 有没有流程可以让
浏览 24提问于2019-03-21得票数 0
我刚接触Apache Kafka和它的与API相关的流服务，但想知道是否有任何正式的文档来获取摄取所需的初始原始数据？从本质上讲，我想尝试构建一个初级的密码交易机器人，但我的印象是http API可能比与Kafka Streams集成的API具有更多的延迟。例如，我知道RapidAPI有一个可以访问的http库，可以帮助提取数据，但我不确定如果我想通过Kafka Streams摄取数据，是否有类似的东西。我试着在Google上挖掘，但不是很清楚Kafka Streams
浏览 0提问于2021-06-05得票数 0
我正在使用Java1.6运行我的应用程序，并计划将一些方面与Kafka集成。
我正在探索是否应该使用Kafka Consumer (使用poll())或使用KafkaStreams API。我们需要Java 1.7 / 1.8来使用Stream API吗？
浏览 3提问于2018-12-20得票数 0
在过去的两周里，我一直在学习apache kafka，我设法理解了kafka的功能，kafka生产者和消费者的工作原理。现在我想设计一个小的java程序，我可以将我的apache tomcat9日志和指标发送给kafka，因为它可以用于日志聚合目的。我已经搜索了如何做到这一点，任何方法或工具，我必须学会设计，我开始了解Log4j.jar，通过它我可以在apache tomcat中生成自定义日志，但我不知道如何将此日志发送到kafka？请提供</
浏览 18提问于2021-08-02得票数 0
我已经在本地机器上设置了apache kafka，并且工作正常，当我将一条消息发布到生产者中时，它立即在消费者提示中流动。
可以从我的本地文件夹配置连续文件流吗？我该怎么做呢？我可以编写一个java应用程序来配置我的生产者吗？
浏览 0提问于2016-07-28得票数 0
已经使用生产者推送了消息。它将100000条消息推送到该主题。使用命令: bin/kafka- producer -perf-test.sh --broker-list localhost:9092 --messages 100000 --topic perfAtlasTopic获取以下生产者指标。) 2015-02-19 00:33:44:020,2015-02-19 00:33:46:822，0,100000,35688.7937
使用以下命令: bin&
浏览 4提问于2015-02-19得票数 3
云服务器
ICP备案
云直播
即时通信 IM
对象存储
腾讯云开发者
