我把问题解决了，
像这样在morphline中添加了try-catch代码块

morphlines: [
  {
    id: convertJsonToAvro
    importCommands: [ "org.kitesdk.**" ]
    commands: [
       {
         tryRules {
              catchExceptions : true
           rules : [
             {
               commands : [
                 # save initial state
                 { readJson {} }
                # extract JSON objects into fields
              { extractJsonPaths {
                flatten: true
                paths: {
            PROJECT_NAME: /PROJECT_NAME
            WSDL_NAME: /WSDL_NAME
            ....
            ....
            ....
            MESSAGE_OUT: /MESSAGE_OUT
        }
      } }
      # convert the extracted fields to an avro object
      # described by the schema in this field
      { toAvro {
        schemaFile:/u0x/myPath/myAvroSchema.avsc
      } }
      # serialize the object as avro
      { writeAvroToByteArray: {
        format: containerlessBinary
              } }
           ]
         }
         {
          commands : [
            { logWarn { format : "Ignoring record with unsupported input format in myLogService: {}", args : ["@{}"] } }
            { dropRecord {} }    
            ]
         }
       ]
     }   
    }    
   ]
  }
]

在 tryRules 我强制代码捕获所有异常。
在 rules: 你可以写 "command:" 阻塞任何您想要的，如果其中一个抛出除最后一个命令块之外的异常，最后一个命令将运行。记住最后一个是“抓住”。我的意思是，如果第一个命令块失败，最后一个（第二个）命令将运行。若第一个命令运行得很好，最后一个命令就不能工作，因为最后一个命令块的工作方式和catch块类似。
所以当代码 readJson {} 在第一个命令块中失败，它抛出一个异常，最后一个命令（catch块）处理它，这样它就不会尝试在kafka主题中接收当前数据，因为它将运行 dropRecord {} .
有关详细文档，请访问kitesdk。