KafkaConsumerBundle | KafkaConsumerBundle | |||
---|---|---|---|---|
Compiled from "KafkaConsumerBundle.java" | Compiled from "KafkaConsumerBundle.java" | |||
public abstract class io.dropwizard.kafka.KafkaConsumerBundle<K, V, T exten ds javax.ws.rs.core.Configuration> implements io.dropwizard.ConfiguredBundl e<T> { | public abstract class io.dropwizard.kafka.KafkaConsumerBundle<K, V, T exten ds io.dropwizard.Configuration> implements io.dropwizard.ConfiguredBundle<T > { | |||
protected io.dropwizard.kafka.KafkaConsumerBundle(java.util.Collection<ja va.lang.String>, org.apache.kafka.clients.consumer.ConsumerRebalanceListene r); | protected io.dropwizard.kafka.KafkaConsumerBundle(java.util.Collection<ja va.lang.String>, org.apache.kafka.clients.consumer.ConsumerRebalanceListene r); | |||
protected io.dropwizard.kafka.KafkaConsumerBundle(java.util.Collection<ja va.lang.String>, org.apache.kafka.clients.consumer.ConsumerRebalanceListene r, java.util.Map<java.lang.String, java.lang.Object>); | protected io.dropwizard.kafka.KafkaConsumerBundle(java.util.Collection<ja va.lang.String>, org.apache.kafka.clients.consumer.ConsumerRebalanceListene r, java.util.Map<java.lang.String, java.lang.Object>); | |||
public void initialize(io.dropwizard.setup.Bootstrap<?>); | public void initialize(io.dropwizard.setup.Bootstrap<?>); | |||
public void run(T, io.dropwizard.setup.Environment) throws java.lang.Exce ption; | public void run(T, io.dropwizard.setup.Environment) throws java.lang.Exce ption; | |||
public abstract io.dropwizard.kafka.KafkaConsumerFactory<K, V> getKafkaCo nsumerFactory(T); | public abstract io.dropwizard.kafka.KafkaConsumerFactory<K, V> getKafkaCo nsumerFactory(T); | |||
public org.apache.kafka.clients.consumer.Consumer<K, V> getConsumer(); | public org.apache.kafka.clients.consumer.Consumer<K, V> getConsumer(); | |||
public void run(java.lang.Object, io.dropwizard.setup.Environment) throws java.lang.Exception; | public void run(java.lang.Object, io.dropwizard.setup.Environment) throws java.lang.Exception; | |||
} | } | |||
End of changes. 1 change blocks. | ||||
1 lines changed or deleted | 1 lines changed or added | |||
This html diff was produced by rfcdiff 1.41. The latest version is available from http://tools.ietf.org/tools/rfcdiff/ |