setMaxLength(int); static void <clinit>(); } org/apache/commons/codec/StringEncoder.class package org.apache.commons.codec; public abstract interface StringEncoder extends Encoder { public abstract String encode(String) throws EncoderException; } org/apache/commons/codec/StringEncoderCompara.class package org.apache.commons.codec; public synchronized class StringEncoderCompara implements java.util.Comparator { private StringEncoder stringEncoder; public void StringEncoderCompara(); public void StringEncod...

	if err != nil {
		return nil, err
	}

	return &sarama.ProducerMessage{
		Topic: target.args.Topic,
		Key:   sarama.StringEncoder(key),
		Value: sarama.ByteEncoder(data),
	}, nil
}

// Close - closes underneath kafka connection.
func (target *KafkaTarget) Close() error {
	close(target.quitCh)

	if target.producer != nil {