Open mjwillson opened 10 years ago
See the comment added below:
public <V> KafkaProducer<?, V> build(final Class<? extends Encoder<V>> messageEncoder, final Environment environment, final String name) { // FIXME this is passing the messageEncoder as the keyEncoder return build(messageEncoder, null, environment, name); } public <K, V> KafkaProducer<K, V> build(final Class<? extends Encoder<K>> keyEncoder, final Class<? extends Encoder<V>> messageEncoder, final Environment environment, final String name) { return build(keyEncoder, messageEncoder, null, environment, name); }
See the comment added below: