程序包 xin.manong.weapon.base.kafka

接口 KafkaRecordProcessor

  • public interface KafkaRecordProcessor
    kafka数据处理接口
    作者:
    frankcl

    • 方法概要

      所有方法 实例方法 抽象方法 
      修饰符和类型 方法 说明
      void process​(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],​byte[]> consumerRecord)
      处理kafka数据，处理失败抛出异常

    • 方法详细资料

      • process

        void process​(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],​byte[]> consumerRecord)
      throws Exception
        处理kafka数据，处理失败抛出异常
        参数:
        consumerRecord - 数据
        抛出:
        Exception