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.