Большое спасибо за видео, но у меня при тестировании возникла ошибка, с которой я не знаю как справиться. Поднимаю Docker-compose (с конфигом из вашего видео) и у меня почему создаются очень странные топики вида Topic: withdraw-money-topic TopicId: 7aEC2jJOQM-7zIKgZExkwQ PartitionCount: 3 ReplicationFactor: 3 Configs: min.insync.replicas=2 Topic: withdraw-money-topic Partition: 0 Leader: 2 Replicas: 2,3,1 Isr: 2 Topic: withdraw-money-topic Partition: 1 Leader: 3 Replicas: 3,1,2 Isr: 3 Topic: withdraw-money-topic Partition: 2 Leader: 1 Replicas: 1,2,3 Isr: 1,2,3 Из-за этого всё падает т.к. указывает что не соблюдается кол-во insync реплик, почему он их так криво балансит я не знаю. Пытался в Java коде менять бины отвечающие за создание топика - не помогло. Вручную создавал топики - при создании внутри контейнера всё хорошо, но как только стартую микросервисы получается такая же картина что приводил выше.
Попробуйте почистить докер(образы, volumes для kafka), рестартануть комп, скорее всего пройдет. Понятно что если уменьшить в конфиге до 1 min.insync.replicas то тоже запуститься, но лучше почистить, чтобы запустилось корректно
@@java-guru volumes каждый раз чистил. Очень интересная ситуация сейчас, ребутнул всё, почистил, поставил репликейшен фактор в 1 и всё та же ошибка, говорит что не соблюдается условия кол-во реплик :) Error: NOT_ENOUGH_REPLICAS. Error Message: Unable to verify the partition has been added to the transaction. Underlying error: NOT_COORDINATOR
@@1aazy В KafkaConfig .configs(Map.of("min.insync.replicas","1")) сделали да? Он не видит других синхронизированных реплик, надо разбираться почему, я могу предположить что из-за докера или из-за невнимательности с конфигами брокеров. У меня была такая ошибка на винде с докер десктопом, почистить докер и ребут помог.
@@java-guru Проблема действительно была в докере, а именно компоус файле. В настройке KAFKA_CFG_ADVERTISED_LISTENER стояла не тот id. Всё исправил и заработало, но убил пару часов :)
Большое спасибо за плейлист по кафке, отличная подача материала.
Спасибо!)
Спасибо за видео! Как всегда очень интересно, доступно и познавательно
Спасибо за отзыв)
Чел, супер круто! Спасибо, за видос!
Спасибо)))
ждем про компенсирующие транзакции)
ок, будет продолжение по кафке
Круто! Спасибо.
Спасибо)
Как всегда на высоте! Отличное видео
Спасибо!
Андрей снимите плз видео по интеграционному тестированию кафки, таких почти нет в инете
Снял)
Большое спасибо за видео, но у меня при тестировании возникла ошибка, с которой я не знаю как справиться.
Поднимаю Docker-compose (с конфигом из вашего видео) и у меня почему создаются очень странные топики вида
Topic: withdraw-money-topic TopicId: 7aEC2jJOQM-7zIKgZExkwQ PartitionCount: 3 ReplicationFactor: 3 Configs: min.insync.replicas=2
Topic: withdraw-money-topic Partition: 0 Leader: 2 Replicas: 2,3,1 Isr: 2
Topic: withdraw-money-topic Partition: 1 Leader: 3 Replicas: 3,1,2 Isr: 3
Topic: withdraw-money-topic Partition: 2 Leader: 1 Replicas: 1,2,3 Isr: 1,2,3
Из-за этого всё падает т.к. указывает что не соблюдается кол-во insync реплик, почему он их так криво балансит я не знаю. Пытался в Java коде менять бины отвечающие за создание топика - не помогло. Вручную создавал топики - при создании внутри контейнера всё хорошо, но как только стартую микросервисы получается такая же картина что приводил выше.
Попробуйте почистить докер(образы, volumes для kafka), рестартануть комп, скорее всего пройдет. Понятно что если уменьшить в конфиге до 1 min.insync.replicas то тоже запуститься, но лучше почистить, чтобы запустилось корректно
@@java-guru volumes каждый раз чистил. Очень интересная ситуация сейчас, ребутнул всё, почистил, поставил репликейшен фактор в 1 и всё та же ошибка, говорит что не соблюдается условия кол-во реплик :)
Error: NOT_ENOUGH_REPLICAS. Error Message: Unable to verify the partition has been added to the transaction. Underlying error: NOT_COORDINATOR
@@1aazy В KafkaConfig .configs(Map.of("min.insync.replicas","1")) сделали да? Он не видит других синхронизированных реплик, надо разбираться почему, я могу предположить что из-за докера или из-за невнимательности с конфигами брокеров. У меня была такая ошибка на винде с докер десктопом, почистить докер и ребут помог.
@@java-guru Проблема действительно была в докере, а именно компоус файле. В настройке KAFKA_CFG_ADVERTISED_LISTENER стояла не тот id. Всё исправил и заработало, но убил пару часов :)
ссылка на репозиторий не работает ((
Исправил