Чтение данных Kafka из KSQL | Повышайте свой уровень KSQL с помощью Confluent

Попробуйте KSQL: https://confluent.io/ksql | В этом видео показано, как исследовать данные тем Kafka, создавать потоки (STREAM) или таблицы (TABLE) на основе тем Kafka, определять поля, объясняются метаданные, такие как ROWTIME и TIMESTAMP, а также рассматриваются различные форматы, такие как Avro, JSON и Delimited.

KSQL — это потоковый SQL-движок с открытым исходным кодом, лицензированный Apache 2.0, который реализует непрерывные интерактивные запросы к Apache Kafka®. KSQL упрощает чтение, запись и обработку потоковых данных в режиме реального времени и в любом масштабе, используя семантику, подобную SQL. Это предлагает простой способ выражения преобразований потоковой обработки в качестве альтернативы написанию приложений на Java или Python. KSQL предоставляет такие возможности, как потоковые соединения, агрегации, оконное управление по времени событий и многое другое!

Узнайте больше о ksqlDB, преемнике KSQL: https://ksqldb.io

О CONFLUENT
Confluent, основанный создателями Apache Kafka®, позволяет организациям извлекать пользу из данных в режиме реального времени. Платформа Confluent управляет потоками потоковых данных и обеспечивает к ним доступ в рамках всей организации. Она предоставляет различным отраслям, от розничной торговли, логистики и производства до финансовых услуг и социальных сетей, масштабируемый, унифицированный конвейер данных в режиме реального времени, который позволяет использовать различные приложения: от интеграции больших объемов данных до анализа больших данных с помощью Hadoop и потоковой обработки в режиме реального времени. Подробнее см. на сайте http://confluent.io