[KAFKA-303] Dead code in the Log4j appender

• Type: Improvement
• Status: Resolved
• Priority: Trivial
• Resolution: Fixed
• Fix Version/s: 0.7.1
• Component/s: core
• Labels: log4j
• Assignee: Unassigned
• Reporter: Jose Quinteiro
• Created: 14/Mar/12 17:55
• Updated: 21/Mar/12 00:38
• Resolved: 21/Mar/12 00:38

Description

The log4j appender has the following class definition in it:

class DefaultStringEncoder extends Encoder[LoggingEvent] {
override def toMessage(event: LoggingEvent):Message = new Message(event.getMessage.asInstanceOf[String].getBytes)
}

This left over and no longer used. The current version uses kafka.serializer.StringEncoder as the default encoder.