Class MessageReaderFactory

java.lang.Object
org.apache.drill.exec.store.kafka.decoders.MessageReaderFactory

public class MessageReaderFactory extends Object
  • Constructor Details

    • MessageReaderFactory

      public MessageReaderFactory()
  • Method Details

    • getMessageReader

      public static MessageReader getMessageReader(String messageReaderKlass)
      Initialize kafka message reader based on store.kafka.record.reader session property
      Parameters:
      messageReaderKlass - value of store.kafka.record.reader session property
      Returns:
      kafka message reader
      Throws:
      UserException - in case of any message reader initialization