Uses of Interface
org.apache.storm.kafka.spout.SerializableDeserializer

Packages that use SerializableDeserializer

Package	Description
org.apache.storm.kafka.spout

Uses of SerializableDeserializer in org.apache.storm.kafka.spout

Methods in org.apache.storm.kafka.spout with parameters of type SerializableDeserializer

Modifier and Type	Method and Description
<NK> KafkaSpoutConfig.Builder<NK,V>	KafkaSpoutConfig.Builder.setKey(SerializableDeserializer<NK> keyDeserializer) Deprecated. Please use KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object) with ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG instead
<NV> KafkaSpoutConfig.Builder<K,NV>	KafkaSpoutConfig.Builder.setValue(SerializableDeserializer<NV> valueDeserializer) Deprecated. Please use KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object) with ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG instead

Constructors in org.apache.storm.kafka.spout with parameters of type SerializableDeserializer

Constructor and Description
Builder(String bootstrapServers, SerializableDeserializer<K> keyDes, SerializableDeserializer<V> valDes, Collection<String> topics) Deprecated. Please use #Builder(java.lang.String, java.util.Collection) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG
Builder(String bootstrapServers, SerializableDeserializer<K> keyDes, SerializableDeserializer<V> valDes, Collection<String> topics) Deprecated. Please use #Builder(java.lang.String, java.util.Collection) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG
Builder(String bootstrapServers, SerializableDeserializer<K> keyDes, SerializableDeserializer<V> valDes, Pattern topics) Deprecated. Please use #Builder(java.lang.String, java.util.regex.Pattern) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG
Builder(String bootstrapServers, SerializableDeserializer<K> keyDes, SerializableDeserializer<V> valDes, Pattern topics) Deprecated. Please use #Builder(java.lang.String, java.util.regex.Pattern) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG
Builder(String bootstrapServers, SerializableDeserializer<K> keyDes, SerializableDeserializer<V> valDes, String... topics) Deprecated. Please use #Builder(java.lang.String, java.lang.String...) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG
Builder(String bootstrapServers, SerializableDeserializer<K> keyDes, SerializableDeserializer<V> valDes, String... topics) Deprecated. Please use #Builder(java.lang.String, java.lang.String...) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG
Builder(String bootstrapServers, SerializableDeserializer<K> keyDes, SerializableDeserializer<V> valDes, Subscription subscription) Deprecated. Please use #Builder(java.lang.String, org.apache.storm.kafka.spout.Subscription) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG
Builder(String bootstrapServers, SerializableDeserializer<K> keyDes, SerializableDeserializer<V> valDes, Subscription subscription) Deprecated. Please use #Builder(java.lang.String, org.apache.storm.kafka.spout.Subscription) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG