Package com.datasift.dropwizard.kafka.producer

Examples of com.datasift.dropwizard.kafka.producer.ManagedProducer

223
224
225
226
227
228
229
230
    public <K, T> KafkaProducer<K, T> build(final Encoder<T> encoder,
                                            final Partitioner<K> partitioner,
                                            final Environment environment,
                                            final String name) {
        final KafkaProducer<K, T> producer = build(encoder, partitioner);
        environment.lifecycle().manage(new ManagedProducer(producer));
        return new InstrumentedProducer<>(producer, environment.metrics(), name);
    }
View Full Code Here
267
268
269
270
271
272
273
274
275
276
277
                                       final Class<? extends Encoder<V>> messageEncoder,
                                       final Class<Partitioner> partitioner,
                                       final Environment environment,
                                       final String name) {
        final Producer<K, V> producer = build(keyEncoder, messageEncoder, partitioner, name);
        environment.lifecycle().manage(new ManagedProducer(producer));
        return new InstrumentedProducer<>(
                producer,
                environment.metrics(),
                name);
    }
View Full Code Here
TOP

Related Classes of com.datasift.dropwizard.kafka.producer.ManagedProducer

  • com.datasift.dropwizard.kafka.KafkaProducerFactory
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.