A
Vitalij
но он будет работать без какого либо ручного вмешательства, или надо его руками из группы кворумов выкинуть?
Нет, надо будет его из иерархического кворума в обычный будет перевести чтобы он заработал, на сколько я понял
Size: a a a
2020 January 20
A
Если бы он сам себя мог перевести, то был бы возможен сплит брейн и в двух ДЦ оба кворума стали бы считать себя главным кворумом
V
Нет, надо будет его из иерархического кворума в обычный будет перевести чтобы он заработал, на сколько я понял
ок, понял, спасибо
2020 January 21
ὦ
Когда у стрима вызывается метод
Это я к чему - достаточно 1 раз вызвать метод
.start, стрим обрабатывает сообщения до тех пор, пока программа (в которой работает стрим) не закончит свое выполнение?Это я к чему - достаточно 1 раз вызвать метод
.start, чтобы стрим работал в background-e?λ
ὦan
Когда у стрима вызывается метод
Это я к чему - достаточно 1 раз вызвать метод
.start, стрим обрабатывает сообщения до тех пор, пока программа (в которой работает стрим) не закончит свое выполнение?Это я к чему - достаточно 1 раз вызвать метод
.start, чтобы стрим работал в background-e?Ты про какое апи друг, фс2 кафка? Кскуель, кстрим, сырой кафка консумер джавовый, альпака
s
Забыл добавить в файл саму команду: bin/sasl-kafka-topics.sh --create --bootstrap-server localhost:9094 --replication-factor 1 --partitions 1 --topic my-topic
Кажется, что этот sh не воспринимает jvm option. Kafka-console-producer.sh и kafka-console-consumer.sh с указанием опций --producer.config и --consumer.config соответственно цепляются к kafka без ошибок.
N
Stretched кластер
По 3 ноды на дц
По 3 ноды на дц
не ясно, как себя поведет кафка, когда связи не будет с одним ДЦ, по идеи в отвалившемся ДЦ все равно будет кворум.
NR
ὦan
Когда у стрима вызывается метод
Это я к чему - достаточно 1 раз вызвать метод
.start, стрим обрабатывает сообщения до тех пор, пока программа (в которой работает стрим) не закончит свое выполнение?Это я к чему - достаточно 1 раз вызвать метод
.start, чтобы стрим работал в background-e?Дважды там и не получится вызвать :) https://kafka.apache.org/20/javadoc/org/apache/kafka/streams/KafkaStreams.html#start--
A
не ясно, как себя поведет кафка, когда связи не будет с одним ДЦ, по идеи в отвалившемся ДЦ все равно будет кворум.
Нету никакой разницы с обычным сетапом
Считайте, что один дц это один сервер в обычном сетапе кафки на 3 сервера
И ведёт она себя также, как если бы между двумя серверами в сетапе из 3 серверов пропала связь
Считайте, что один дц это один сервер в обычном сетапе кафки на 3 сервера
И ведёт она себя также, как если бы между двумя серверами в сетапе из 3 серверов пропала связь
A
Спасибо, интересно :)
A
У нас, кстати, пока единственный неприятный кейс с разрывом сети был когда зукиперы видели весь кластер кафки, а все ноды кафки стали изолированны от внешнего мира
В итоге кластер думал, что он здоров и все ок, а все клиенты сломались и не могли продолжать работать
В итоге кластер думал, что он здоров и все ок, а все клиенты сломались и не могли продолжать работать
AK
У нас, кстати, пока единственный неприятный кейс с разрывом сети был когда зукиперы видели весь кластер кафки, а все ноды кафки стали изолированны от внешнего мира
В итоге кластер думал, что он здоров и все ок, а все клиенты сломались и не могли продолжать работать
В итоге кластер думал, что он здоров и все ок, а все клиенты сломались и не могли продолжать работать
клиенты в смысле клиенты кафки, или ноды кафки(клиенты зукипера)?
A
Ноды кафки перестали видеть внешний мир (друг друга и зукиперов)
A
Но извне их было видно
ὦ
Есть что-то почитать про системы/как правильно делать на event sourcing?
DM
ὦan
Есть что-то почитать про системы/как правильно делать на event sourcing?