1. Обзор​

Apache Flink — это платформа обработки потоков, которую можно легко использовать с Java. Apache Kafka — это распределенная система обработки потоков, поддерживающая высокую отказоустойчивость.

В этом руководстве мы рассмотрим, как построить конвейер данных с использованием этих двух технологий.

2. Установка​

Чтобы установить и настроить Apache Kafka, обратитесь к официальному руководству . После установки мы можем использовать следующие команды для создания новых тем с именами flink_input и flink_output:

1. Обзор​

Kafka — это система обработки сообщений, построенная на основе распределенной очереди сообщений. Он предоставляет библиотеку Java, чтобы приложения могли записывать данные или считывать данные из темы Kafka.

Теперь, поскольку большая часть логики бизнес-домена проверяется с помощью модульных тестов, приложения обычно имитируют все операции ввода-вывода в JUnit. Kafka также предоставляет MockProducer для имитации приложения производителя.

В этом руководстве мы сначала реализуем приложение производителя Kafka. Позже мы реализуем модульный тест для проверки общих операций производителя с помощью MockProducer .

2. Зависимости Maven​

1. Обзор​

В этом руководстве мы кратко представим Apache Kafka , а затем посмотрим, как программно создавать и настраивать разделы в кластере Kafka.

2. Знакомство с Кафкой​

Apache Kafka — это мощная, высокопроизводительная распределенная платформа для потоковой передачи событий.

Как правило, приложения-производители публикуют события в Kafka, а потребители подписываются на эти события, чтобы читать и обрабатывать их. Kafka использует темы для хранения и классификации этих событий, например, в приложении электронной коммерции может быть тема «заказы».

Вот так…

1. Весна и Ява​

>> Отслеживайте и устраняйте неполадки в приложениях и службах Java с помощью Datadog Спонсируется​

Оптимизируйте производительность с помощью сквозной трассировки и встроенной поддержки популярных платформ Java, серверов приложений и баз данных. Попробуйте бесплатно .

>> Мои первые впечатления от Graal VM [ blog.frankel.ch ]​

GraalVM — интересный продукт , но, видимо, еще не очень зрелый.

Вот так…

1. Весна и Ява​

>> Отслеживайте и устраняйте неполадки в приложениях и службах Java с помощью Datadog Спонсируется​

Оптимизируйте производительность с помощью сквозной трассировки и встроенной поддержки популярных платформ Java, серверов приложений и баз данных. Попробуйте .

>> Рефакторинг для коллекций Eclipse: делаем потоки Java компактнее, чище и чище [ infoq.com ]​

Ускоренная обработка потоков с помощью этой простой замены классов Java Collections Framework . Очень круто.

Вот так…

1. Весна и Ява​

>> Отслеживайте и устраняйте неполадки в приложениях и службах Java с помощью Datadog Спонсируется​

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

>> Java по-прежнему бесплатна [ javaspecialists.eu ]​

Эта статья может помочь развеять любые опасения, неуверенность и сомнения, которые могут у вас возникнуть в отношении того, чтобы придерживаться Java . И основательное чтение по теме на InfoQ .

Вот так…

1. Весна и Ява​

>> Переключатели функций в среде микросервисов — Часть 2: Реализация [ blog.codecentric.de ]​

Краткий обзор Unleash, сервиса Node.js для управления переключением функций в наборе микросервисов, с простым примером конфигурации на основе Java.

>> Обмен сообщениями между MBD и MDB: используйте силу дельты реки [ tomitribe.com ]​

Хорошая статья, показывающая, как обмен сообщениями между компонентами, управляемыми сообщениями, может привести к созданию мощных асинхронных архитектур .

Вот так…

1. Весна и Ява​

>> Текстовые блоки Java 13 [ vojtechruzicka.com ]​

Первый взгляд на многострочные строковые литералы в JEP-355: текстовые блоки (предварительная версия) — они не совсем такие же, как необработанные строковые литералы JEP-326, которые были отозваны.

>> Руководство для начинающих по подсказкам запросов JPA и Hibernate [ vladmihalcea.com ]​

Полный список подсказок для запросов JPA, доступных для настройки выполнения запросов в Hibernate .

Вот так…

1. Весна и Ява​

>> Скрытие сервисов и обнаружение во время выполнения с помощью Spring Cloud Gateway [ spring.io ]​

Надежный, готовый к запуску пример с использованием шлюза Spring Cloud и служб реестра. Хорошая вещь.

>> Упражнения в стиле программирования: карты тоже объекты [ blog.frankel.ch ]​

Функциональное решение проблемы извлечения слов, замеченной ранее в серии, на этот раз с использованием неизменяемой карты в Котлине.

Вот так…

1. Весна и Ява​

>> Защита сервисов с помощью Spring Cloud Gateway [ spring.io ]​

По мере продолжения серии мы увидим, как защитить службы с помощью шаблона Token Relay с OAuth2 .

>> Spring Boot на Heroku с Docker, JDK 11 и Maven 3.5.x [ blog.codecentric.de ]​

Docker придет на помощь в случаях , когда вы не можете создать свое приложение, используя предопределенные пакеты сборки Heroku . Очень круто!