Попытка прочитать данные из Kafka в Flume. Я настроил все остальные необходимые детали для источника kafka. Данные из kafka используют ByteArraySerializer.
Однако следующие конфигурации для сериализаторов, похоже, не работают:
flume.sources.kafka-source.kafka.consumer.key.serializer = org.apache.kafka.common.serialization.ByteArraySerializer
flume.sources.kafka-source.kafka.consumer.value.serializer = org.apache.kafka.common.serialization.ByteArraySerializer
Здесь что-то не так?
PS: Я новичок в лотке ie