В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

pro.kafka

1953 membersпожаловаться на группу
2020 October 09

I

IV in pro.kafka
привет! правильно понимаю, для высокой доступности Confluent Schema Registry, нам необходимо несколько нод Confluent Schema Registry настроить на кластер zookeeper - SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL?
источник
13:59пожаловаться#1

I

IV in pro.kafka
или вариант с зукипером деприкейтед?
источник
14:01пожаловаться#2

N

Nikolay in pro.kafka
Никола Абрамович
добрый день, подскажите почему так отличается массив, в какую сторону смотреть что бы сделать одинаковый вывод
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec
брокер А
time,"1602238101813"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:Count,"39"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:EventType,"messages"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:FifteenMinuteRate,"5.6337033933972067E-5"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:FiveMinuteRate,"4.825215829996067E-8"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:MeanRate,"1.4275355884538996E-4"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:OneMinuteRate,"1.3081400668568506E-28"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:RateUnit,"SECONDS"

брокер Б
time,"1602238113050"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:Count,"31030878"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:EventType,"messages"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:FifteenMinuteRate,"3.3601989093524973"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:FiveMinuteRate,"3.359907915740408"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:MeanRate,"2.4259470055094075"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:OneMinuteRate,"3.423625417302397"
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec:RateUnit,"SECONDS"
А какая конфигурация ? Может к вам 2 брокера и один топик  с одной партией.
источник
14:04пожаловаться#3

V

Vadim in pro.kafka
https://issues.apache.org/jira/browse/ZOOKEEPER-2332
источник
14:04пожаловаться#4

V

Vadim in pro.kafka
походу баг висит 4 года
источник
14:05пожаловаться#5

V

Vadim in pro.kafka
что сделать сейчас чтобы запустить?
источник
14:05пожаловаться#6

V

Vadim in pro.kafka
данные зукипера можно почистить вообще? там же просто кто какой топик , какую партицию читает? заного подключатся и все
источник
14:05пожаловаться#7

N

Nikolay in pro.kafka
Vadim
данные зукипера можно почистить вообще? там же просто кто какой топик , какую партицию читает? заного подключатся и все
Там хранится эпоха для топика.
источник
14:07пожаловаться#8

V

Vadim in pro.kafka
чет не знаю что это
источник
14:07пожаловаться#9

N

Nikolay in pro.kafka
Кто читает насколько мне помнится там не хранится.
источник
14:07пожаловаться#10

V

Vadim in pro.kafka
https://quickview.cloudapps.cisco.com/quickview/bug/CSCvm58786
Cisco
Cisco Bug: CSCvm58786 - Known issue in Zookeeper 3.4.6 results in Zookeeper becoming unavailable on cluster manager
Symptom: Zookeeper was in an endless restart cycle due to monit on the cluster manager: Process 'zookeeper-server' Initializing The logs included stack dumps like: 2018-08-27 22:10:58,514 [myid:] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@1007] - Closed socket connection for client /192.168.2.109:47860 (no session established for client) 2018-08-27 22:10:58,517 [myid:] - ERROR [main:Util@239] - Last transaction was partial. 2018-08-27 22:10:58,517 [myid:] - ERROR [main:ZooKeeperServerMain@63] - Unexpected exception, exiting abnormally java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.java:392) at org.apache.jute.BinaryInputArchive.readInt(BinaryInputArchive.java:63) at org.apache.zookeeper.server.persistence.FileHeader.deserialize(FileHeader.java:64) at org.apache.zookeeper.server.persistence.FileTxnLog$FileTxnIterator.inStreamCreated(FileTxnLog.java:576) at org.apache.zookeeper.server.persistence.FileTxnLog$FileTxnIterator.createInputArchive(FileTxnLog.java:595) at…
источник
14:08пожаловаться#11

V

Vadim in pro.kafka
удалил файл 0го размера. запустился зукипер
источник
14:08пожаловаться#12

V

Vadim in pro.kafka
retention policy поменял, сделал по размеру чтоб чистилось, запустил, но чет пока не чистит
источник
14:10пожаловаться#13

V

Vadim in pro.kafka
о хотя почистил
источник
14:11пожаловаться#14

ON

Oleg Nyrkov in pro.kafka
Сижу пишу велосипед, может кто написал уже? Вычитываем из кафки сообщения и раскладываем по локальным очередям, сейчас коммит делаем после того как положили сообщения в локальную очередь. Вот решили что можем потерять сообщения если упадем, и делать более умный управляемый коммит.  Может знает уже готовое, кейс вроде стандартный, должно же где то быть уже реализованное
источник
14:18пожаловаться#15

НА

Никола Абрамович... in pro.kafka
Nikolay
А какая конфигурация ? Может к вам 2 брокера и один топик  с одной партией.
4-брокера 40-топиков, на 3-х нормальный stdout из kafka.tools.JmxTool, а на 4-м такая шляпа 5.6337033933972067E-5
источник
14:22пожаловаться#16

N

Nikolay in pro.kafka
Никола Абрамович
4-брокера 40-топиков, на 3-х нормальный stdout из kafka.tools.JmxTool, а на 4-м такая шляпа 5.6337033933972067E-5
А на этом 4 как дела вообще ? Идут на него сообщения ? Есть он в isr?
источник
14:23пожаловаться#17

НА

Никола Абрамович... in pro.kafka
Topic:ucd-inbox PartitionCount:1        ReplicationFactor:4     Configs:min.insync.replicas=3
        Topic: ucd-inbox        Partition: 0    Leader: 4       Replicas: 4,3,2,1       Isr: 2,4,3,1
Topic:ucd-outbox        PartitionCount:1        ReplicationFactor:4     Configs:min.insync.replicas=3
        Topic: ucd-outbox       Partition: 0    Leader: 4       Replicas: 4,3,2,1       Isr: 1,4,3,2
Topic:utd-inbox PartitionCount:1        ReplicationFactor:4     Configs:min.insync.replicas=3
        Topic: utd-inbox        Partition: 0    Leader: 4       Replicas: 3,4,2,1       Isr: 1,4,3,2
Topic:utd-outbox        PartitionCount:1        ReplicationFactor:4     Configs:min.insync.replicas=3
        Topic: utd-outbox       Partition: 0    Leader: 4       Replicas: 4,3,2,1       Isr: 1,4,3,2

нормально все, отдает и принимает.
источник
14:27пожаловаться#18

НА

Никола Абрамович... in pro.kafka
аномалия какая то не типизированных данных
источник
14:34пожаловаться#19

e

es]x in pro.kafka
Подскажите каким параметром можно чистить tmp/kafka-logs &&
источник
20:26пожаловаться#20