Байт Kafka отклонен в мониторинге - PullRequest
2 голосов
/ 09 января 2020

У нас установлено 8 узлов kafka cluster и kafka manager.

Мы осуществляем мониторинг через новую версию c.

новый Reli c и менеджер kafka оба сообщают, что kafka отклоняет байты. Я не могу найти причину.

В логах брокера нет строк ошибок.

JMS BEAN - JMX / kafka.server / BrokerTopicMetrics / BytesRejectedPerSec / OneMinuteRate

enter image description here enter image description here

Kafka Config -

auto.create.topics.enable=false
auto.leader.rebalance.enable=true
broker.id=180
controlled.shutdown.enable=true
controlled.shutdown.max.retries=3
default.replication.factor=1
delete.topic.enable=true
kafka.http.metrics.host=0.0.0.0
kafka.http.metrics.port=24042
kafka.log4j.dir=/logs/kafka
kerberos.auth.enable=false
leader.imbalance.check.interval.seconds=300
leader.imbalance.per.broker.percentage=10
log.cleaner.dedupe.buffer.size=134217728
log.cleaner.delete.retention.ms=604800000
log.cleaner.enable=true
log.cleaner.min.cleanable.ratio=0.5
log.cleaner.threads=1
log.dirs=/kafka/data
log.retention.bytes=5368709120
log.retention.check.interval.ms=300000
log.retention.hours=72
log.retention.ms=259200000
log.roll.hours=168
log.segment.bytes=1073741824
message.max.bytes=3145728
min.insync.replicas=1
num.io.threads=8
num.partitions=1
num.replica.fetchers=6
offsets.topic.num.partitions=50
offsets.topic.replication.factor=3
port=9092
quota.consumer.default=52428800
quota.consumer.default=52428800
quota.producer.default=26214400
quota.producer.default=26214400

replica.fetch.max.bytes=4194304
replica.lag.max.messages=6000
replica.lag.time.max.ms=60000
unclean.leader.election.enable=false
zookeeper.session.timeout.ms=6000
zookeeper.connect=zookeeper01.prod.***.com:2181,zookeeper02.prod.***.com:2181,zookeeper03.prod.***.com:2181
security.inter.broker.protocol=PLAINTEXT

listeners=PLAINTEXT://kafka01.prod.***.com:9092,
broker.id.generation.enable=false
sasl.kerberos.service.name=kafka
listeners=PLAINTEXT://:9092
num.network.threads=8

1 Ответ

0 голосов
/ 03 мая 2020

Изучая источники Кафки ( ref1 , ref2 ), кажется, что единственная причина, учитываемая в BytesRejectedPerSe c (bytesRejectedRate), это размер сообщения, превышающий config.maxMessageSize.

Примечание. Повторное сжатие и преобразование формата сообщения также могут влиять на размер сообщения, превышающий размер отправляемого производителем.

...