Общение микросервисов между собой | Java | Kafka на практике
ฝัง
- เผยแพร่เมื่อ 13 ต.ค. 2024
- 🖖 Приветствую на пятом занятии из серии уроков по написанию REST API.
В этой части я покажу как:
▫️ Создать kafka-topic через Spring
▫️ Настроить работу Producer-а и Consumer-а на один топик
▫️ Общаются сервисы друг с другом
📫 Обратная связь - pavel.stanislavovich.ge@gmail.com
👉 Другие курсы на Stepik - stepik.org/use...
🔥 Telegram канал - t.me/NerzonCha...
Чувак не бросай видосы про java, очень полезная информация )
Спасибо большое за обратную связь❤️😇
актуальная тема, весь финтех на ней, современный
Спасибо за отзыв!)
Rabbit ещё, не только кафка
отличная подача, приятно слушать)
Спасибо большое 😇
Спасибо за видео! Попробовал несколько гайдов, было не всегда понятно и куча лишнего, у вас прям всё лаконично и просто всё✨
Спасибо большое, стараюсь)
Спасибо за видео, да на ютуюе много видео по теорий но вот на практике да еще в паре с java видео почти нет
Спасибо большое за отзыв ❤️
Это был славный бой ) 2 дня Поднимал кафку и зукипер на компе. Еще пол дня искалу куда добавить переменные среды в Идее. Спасибо, учитель 🤝
Молодец подаван🫡
Спасибо за материал, очень полезный и с подачей все супер! Единственный момент, не забудьте в .properties подкорректировать данные подключения к базе после предыдущего видео с docker-compose) так же хороший комментарий про kafka в docker-compose. Я развернул, + так же в idea плагин kafka поставил, все красиво))
Спасибо большое за обратную свзяь!
Спасибо! Интересно!
Благодарю 😇
Мое уважение и огромное человеческое спасибо.
Может запилишь курс на темы Redis, Apache kafka, Микросервисы с конкретными кейсами. С удоволствием купил бы
Это большой объем работы, а с количеством разных дел не могу усесться и курс по структурам данных закончить.
Но планирую сделать хороший теоретический материал по Spring-у от А до микросервисов.
Когда необходимо узнать типы, названия и порядок параметров метода, поставьте курсор внутри скобок и нажмите Ctrl + P в операционных системах Windows и Linux или Cmd + P на macOS. Очень удобный хоткей.
заебок видос, для начинающих по kafka
Благодарю 🤌
вот это зачетно и понятно! так держать!
Спасибо ❤️
как же он хорош
Спасибо за полезное видео!
Спасибо, вам, за отзыв!
Красавчик!!!
Спасибо 😇
Кстати, для тех же целей подойдут обычные сокеты. Kafka как раз либо у себя под капотом держит TCP IP, либо UDP
Конечно, в устройстве любой системы лежат более примитивные технологии👌
Отличный материал. А можно увидеть docker-compose для запуска Кафки в докере? Уже несколько видео подобных смотрю, постоянно проблемы
Да, конечно:
Например ->
version: '3.1'
services:
broker:
image: 'имя_образа'
expose:
- '9092'
ports:
- '127.0.0.1:9092:9092'
container_name: broker
depends_on:
- zookeeper
environment:
- KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
- KAFKA_LISTENERS=PLAINTEXT://:9092
- KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://broker:9092
zookeeper:
image: 'имя_образа'
container_name: zookeeper
expose:
- '2181'
...
Далее чере depends_on у других сервисов указываем зависимости на broker.
Добрый день, а будет ли продолжение? Возможно, сложный кейс, типа одновременно 2 брокеров, сценарии обработки ошибок или аналитика?
Спасибо!
Здравствуйте, будет очень много чего ещё нового, в том числе, возможно, буду развивать kafka. Однако сейчас большая загруженность по работе с детьми, поэтому точно будут выходить еженедельные видео про алгоритмические задачи, остальное только по возможности🫡
Привет, дружище, извини за такой нескромный вопрос, но всё-таки задам, работаешь на позиции Java Middle Backend?
Приветствую, в данный момент занимаюсь с детьми и подростками, больше преподаю😇
Про avro, и саму schema registry видео будет?
Скорее всего нет, но я обязательно подумаю! Извините, если не смог вам помочь или, не дай бог, потратил ваше время зря.
В видео убрали момент с разворачиванием кафки в docker?
Конфигурация docker compose файла?
Вот пример организации docker-compose:
version: '3.1'
services:
broker:
image: 'имя_образа'
expose:
- '9092'
ports:
- '127.0.0.1:9092:9092'
container_name: broker
depends_on:
- zookeeper
environment:
- KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
- KAFKA_LISTENERS=PLAINTEXT://:9092
- KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://broker:9092
zookeeper:
image: 'имя_образа'
container_name: zookeeper
expose:
- '2181'
...
Далее чере depends_on у других сервисов указываем зависимости на broker.
конфигурацию можно вписать и в application properties
понравилось
Спасибо большое ❤️
Привет, а почему ты инжектишь репозитрорий прямо в контроллере? Между ними как правило фигурирует слой сервиса, отвечающий за всю бизнес логику...
Всё верно, это же демо пример)
Есть у когото пример исходников простого плагина кафки ?
Особенно круто, если он будет брать из одного топика, преобразовывать данные и класть в другой
К сожалению, не располагаю им😅
звук интро у демдева взял?)
Не знаю кто это🤷
Здравствуйте. А можете показать как на Windows 10 развернуть кафку без докера?
С Windows точных шагов не дам, однако принцип в целом тот же, нужно установить и распаковать архив у себя на компьютере, далее через консоль из запустить. Вот например статья по теме: timeweb.cloud/tutorials/microservices/ustanovka-i-nastroika-kafka
Здравствуйте!!!!
Кто нибудь подскажите пожалуйста где у автора поднята кафка? Зависимость spring-kafka сама все поднимает? К чему приложение подключается?
Спасибо!!!
Kafka, как я помню, поднята просто локально. Гайд по установке и развертывании скидывал в телеграм - t.me/NerzonChannel
Можно ссылку на гит с этими проектами?
github.com/pavelitel05/rest-application-example
почему на старте звук от dmdev стоит? Я уже думал что dmdev смотрю
Не совсем понимаю о чем вы
А как consumer получил сообщение?
вроде догнал
KAFKA_LISTENERS: INSIDE://0.0.0.0:9093,OUTSIDE://0.0.0.0:9092 (docker-compose)
то есть продусер я запустил на 9093 порту, а консумер слушал 9092 порт и вывел топик course?
чел, ты просто наверное забыл, что у тебя автоматом генерится Id
Возможно)
у кого ни будь получилось запустить kafka????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????
Здравствуйте, подскажите, пожалуйста, какие возникли проблемы при запуске?
@@NerzonIT привет🖐️
Многомодульный спринг проект, в 2 модулях будет Кафка! Проблемы:
Не могу запустить ее через терминал, что только не пробовал.
2: попробовал написать docker-compose файл тоже какая то фигня!
3: пару дней по всем группам искал ментора, не желающих, не способных помочь нет!
ну незнаю, все самое интересное вырезал (
Прошу прощения, а какие моменты вас интересуют?
О, вайбы dmdev…
Что это?)
по-моему, объяснение недостаточное, чтобы новичку организовать общение двух микросервисов
Здравствуйте, спасибо, подскажите, что по вашему мнению добавить?
@@NerzonIT запуск самой кафки
джун записывает гайды по большим высоконагруженным системам не зная элементарных вещей в спринге - это сильно
Элементарные вещи, все таки, я знаю. Но да, я делаю гайды на максимально простом языке и в действительности не имею большого опыта в разработке.
В любом случае, надеюсь, что помогаю людям)
запиши свой гайд,а мы оценим
Привет! Перепробовал кучу вариантов в docker-compose.yaml И все равно получаю ошибки создания топика с сообщением :
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers
Ты можешь выложить куда-то docker-compose ?
Привет! В Telegram уже давал людям docker-compose - t.me/NerzonChannel/23
В коментарии к посту
Музончик на фоне
Не понимаю, это вопрос или утверждение)