Skip to content
This repository has been archived by the owner on Nov 28, 2023. It is now read-only.

KafkaProducerFactory build overloads confuse keyEncoder and messageEncoder #26

Open
mjwillson opened this issue Sep 1, 2014 · 0 comments

Comments

@mjwillson
Copy link
Contributor

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);
    }
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant