Apache Kafka – мой конспект

[@tmk826]

И это всё под windows — +5!

[@arylkov]

На винде с файлофой беда, только для моих тестов, не более.

[@mikeGolovanov]

Спасибо за шпаргалку, но есть неточности

>producer.send(new ProducerRecord(topicName, split[0]));
Вот так записывать в Кафку плохо. Вы не анализируете результат работы метода send. Либо нужно вторым параметром передать Callback, либо у полученной в результате вызова Future вызвать метод get.

И да, Windows — неподдерживаемая платформа и на ней из-за особенностей файловой подсистемы кафка вряд ли будет нормально работать в ближайшее время.

[@arylkov]

На винде беда с файловой, тему так и не смог удалить через API, лог часто удалял, кафка падала… Но думаю списывать windows рано, хорошо если исправят эти (считаю) детские болезни.

[@el_gato]

Они это уже 100 лет знают и править походу не собираются, да и зачем? Никто кафку в продакшене на винде держать не будет.

[@shuron]

Коллеги zookeeper все еще обязательный компонент или можно заменить/обойтись без?

[@el_gato]

да, обязательный.

[@baltazorbest]

Спасибо за статью. Возникло пару вопросов, может у вас получится на них ответить, был бы благодарен:
1) Можно ли сделать так что бы сообщение (тема) не удалялась пока ее не прочтут 2 клиента, или же лучше делать 2 одинаковых сообщения для разных клиентов?
2) Как лучше организовать ГЕО синхронизацию? Когда издатель находится в одной стране, а подписчики в другой?
Спасибо.

[@el_gato]

1. Сообщения в топике (теме) удаляются по прошествии времени, сколько они будут храниться можно настроить.
2. Не совсем понятно, что имеется под синхронизацией? Все коммуникации осуществляются через сеть, если кафка смотрит во внешний мир то подключиться к ней можно откуда угодно.

[@arylkov]

Добавил код — KafkaCountStream