flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java [545:551]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        writer.get().write(e, encoder);
        encoder.flush();
        bytes = tempOutStream.get().toByteArray();
      } else {
        bytes = event.getBody();
      }
      return bytes;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flume-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java [448:454]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      writer.get().write(e, encoder);
      encoder.flush();
      bytes = tempOutStream.get().toByteArray();
    } else {
      bytes = event.getBody();
    }
    return bytes;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -