Вопросы с тегом apache--kafka-apache--flink

0 голосов

1 ответ

Что это значит, когда вы получаете «слишком много открытых файлов» на Kafka Consumer / Client?

user432024 / 20 февраля 2020

0 голосов

1 ответ

Flink Avro Serialization показывает ошибку «не сериализуемо» при работе с GenericRecords

kopaka / 30 января 2020

2 голосов

1 ответ

Как я могу применить фильтр в этой схеме avro, используя Apache Flink

whiteskull / 25 января 2020

0 голосов

1 ответ

Десериализовать avro в apache flink, используя слив

whiteskull / 23 января 2020

1 голос

1 ответ

Сбой KafkaAvroDeserializer с исключением из Kyro

Anuj jain / 23 января 2020

0 голосов

0 ответов

Не удалось найти запись «KafkaClient» в конфигурации JAAS

Malatesh R M / 21 января 2020

1 голос

1 ответ

Flink Consumer с DataStream API для пакетной обработки - как мы узнаем, когда нужно остановиться и как остановить обработку [2 раза]

rtnyc / 21 января 2020

0 голосов

1 ответ

Десериализация в потоке данных Flink

Noobie / 20 января 2020

0 голосов

1 ответ

Настройка проекта коннектора kafka flink с примером

Noobie / 19 января 2020

0 голосов

1 ответ

зависимость в pom. xml не работает в примере соединителя flink kafka

Noobie / 18 января 2020

0 голосов

0 ответов

Почему мое потоковое задание Flink на AWS EMR выполняется в локальном мини-кластере?

Patrick / 16 января 2020

0 голосов

0 ответов

flink 1.9.1 java .lang.NoClassDefFoundError: org / apache / flink / streaming / connectors / kafka / FlinkKafkaConsumer

jiangchao / 12 января 2020

Страница:

...