首页 文章

Kafka 制片人表现不佳

提问于
浏览 次
0

我和kafka制作人有问题 . 其实我正在使用spring kafka，并通过KafkaTemplate发送消息：

DefaultKafkaProducerFactory<K, V> defaultKafkaProducerFactory = new DefaultKafkaProducerFactory<>(producerParams);
KafkaTemplate kafkaTemplate = new KafkaTemplate<>(defaultKafkaProducerFactory);
RecordMetadata recordMetadata = kafkaTemplate.send(record).get().getRecordMetadata();

问题是有时发送消息需要4-20秒 . 有很多消息需要100毫秒才能发送 . 所以我几乎没有问题：

  • 消息大小和吞吐量之间是否存在任何关联，这种关系是什么？

  • 我应该先检查一下，也许我没有做好调音，任何方向？

apache-kafka messaging producer-consumer kafka-producer-api spring-kafka

1 回答

  • 2

    好吧，实际上问题出现在机器上，cpu很高，Cloudera经理中有日志

    检测到JVM或主机中的暂停（例如，停止世界GC或未安排的JVM）：暂停约4332ms：未检测到GC . 检测到JVM或主机中的暂停（例如，停止世界GC或未安排的JVM）：暂停大约10827ms：GC池'ConcurrentMarkSweep'有集合：count = 1 time = 11107ms

    当我在具有8个核心的机器上运行相同时 - 问题就消失了 . 建议的另一件事是增加 Java Heap Size of Broker

    回复于

相关问题