Deprecated List (Storm 1.2.4 API)

Deprecated Interfaces
Interface and Description
org.apache.storm.druid.bolt.DruidBeamFactory the preferred way to ingest streaming events to druid is through Kafka, as such storm-druid is deprecated and will be removed in 2.x releases of storm.
org.apache.storm.druid.bolt.ITupleDruidEventMapper the preferred way to ingest streaming events to druid is through Kafka, as such storm-druid is deprecated and will be removed in 2.x releases of storm.
org.apache.storm.kafka.spout.SerializableDeserializer Avoid using this class. Use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with `ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG` and `ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG` instead

Deprecated Classes
Class and Description
org.apache.storm.serialization.DefaultSerializationDelegate
org.apache.storm.druid.bolt.DruidBeamBolt the preferred way to ingest streaming events to druid is through Kafka, as such storm-druid is deprecated and will be removed in 2.x releases of storm.
org.apache.storm.druid.trident.DruidBeamState the preferred way to ingest streaming events to druid is through Kafka, as such storm-druid is deprecated and will be removed in 2.x releases of storm.
org.apache.storm.druid.trident.DruidBeamStateFactory the preferred way to ingest streaming events to druid is through Kafka, as such storm-druid is deprecated and will be removed in 2.x releases of storm.
org.apache.storm.druid.trident.DruidBeamStateUpdater the preferred way to ingest streaming events to druid is through Kafka, as such storm-druid is deprecated and will be removed in 2.x releases of storm.
org.apache.storm.druid.bolt.DruidConfig the preferred way to ingest streaming events to druid is through Kafka, as such storm-druid is deprecated and will be removed in 2.x releases of storm.
org.apache.storm.serialization.GzipBridgeSerializationDelegate
org.apache.storm.kafka.bolt.KafkaBolt Please use the KafkaBolt in storm-kafka-client
org.apache.storm.kafka.KafkaSpout storm-kafka has been deprecated and will be removed in a future Storm release. Please upgrade to storm-kafka-client. If you need to migrate the committed offsets to the new spout, consider using the storm-kafka-migration tool.
org.apache.storm.kafka.spout.NamedSubscription Please use `ManualPartitionSubscription` with `NamedTopicFilter` instead
org.apache.storm.kafka.trident.OpaqueTridentKafkaSpout storm-kafka has been deprecated and will be removed in a future Storm release. Please upgrade to storm-kafka-client. If you need to migrate the committed offsets to the new spout, consider using the storm-kafka-migration tool.
org.apache.storm.kafka.spout.PatternSubscription Please use `ManualPartitionSubscription` with `PatternTopicFilter` instead
org.apache.storm.security.auth.SimpleTransportPlugin Use PlainSaslTransportPlugin instead as default insecure transport plugin
org.apache.storm.testing.SingleUserSimpleTransport This is no longer available for testing purpose.
org.apache.storm.utils.TimeCacheMap
org.apache.storm.transactional.TransactionalTopologyBuilder
org.apache.storm.kafka.trident.TransactionalTridentKafkaSpout storm-kafka has been deprecated and will be removed in a future Storm release. Please upgrade to storm-kafka-client. If you need to migrate the committed offsets to the new spout, consider using the storm-kafka-migration tool.
org.apache.storm.kafka.trident.TridentKafkaState storm-kafka has been deprecated and will be removed in a future Storm release. Please upgrade to storm-kafka-client.
org.apache.storm.druid.bolt.TupleDruidEventMapper the preferred way to ingest streaming events to druid is through Kafka, as such storm-druid is deprecated and will be removed in 2.x releases of storm.

Deprecated Fields
Field and Description
org.apache.storm.Config.DRPC_MAX_BUFFER_SIZE As SimpleTrasportPlugin is deprecated, no other thrift transport plugin uses this configuration.
org.apache.storm.Config.NIMBUS_HOST
org.apache.storm.Config.NIMBUS_THRIFT_MAX_BUFFER_SIZE As SimpleTrasportPlugin is deprecated, no other thrift transport plugin uses this configuration.
org.apache.storm.Config.PACEMAKER_HOST in favor of PACEMAKER_SERVERS for Pacemaker-HA.
org.apache.storm.Config.STORM_MESSAGING_NETTY_MAX_RETRIES "Since netty clients should never stop reconnecting - this does not make sense anymore.
org.apache.storm.Config.TOPOLOGY_DISRUPTOR_WAIT_STRATEGY this is no longer supported Configure the wait strategy used for internal queuing. Can be used to tradeoff latency vs. throughput
org.apache.storm.Config.ZMQ_HWM
org.apache.storm.Config.ZMQ_LINGER_MILLIS
org.apache.storm.Config.ZMQ_THREADS

Deprecated Methods
Method and Description
org.apache.storm.drpc.LinearDRPCTopologyBuilder.addBolt(IRichBolt)
org.apache.storm.drpc.LinearDRPCTopologyBuilder.addBolt(IRichBolt, Number)
org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions.addRotationAction(RotationAction)
org.apache.storm.sql.parser.impl.SimpleCharStream.getColumn()
org.apache.storm.kafka.spout.KafkaSpoutConfig.getKeyDeserializer() Please use `KafkaSpoutConfig.getKafkaProps()` and look up the entry for `ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG` instead
org.apache.storm.sql.parser.impl.SimpleCharStream.getLine()
org.apache.storm.security.auth.ThriftConnectionType.getMaxBufferSize(Map) As SimpleTrasportPlugin is deprecated, no other thrift transport plugin uses this method.
org.apache.storm.task.TopologyContext.getRegisteredMetricByName(String)
org.apache.storm.tuple.TupleImpl.getSourceGlobalStreamid()
org.apache.storm.tuple.Tuple.getSourceGlobalStreamid() replaced by `Tuple.getSourceGlobalStreamId()` due to broken naming convention
org.apache.storm.kafka.spout.KafkaSpoutConfig.getValueDeserializer() Please use `KafkaSpoutConfig.getKafkaProps()` and look up the entry for `ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG` instead
org.apache.storm.kafka.spout.KafkaSpoutConfig.isConsumerAutoCommitMode() Use `KafkaSpoutConfig.getProcessingGuarantee()` instead.
org.apache.storm.security.INimbusCredentialPlugin.populateCredentials(Map<String, String>, Map)
org.apache.storm.task.TopologyContext.registerMetric(String, ICombiner, int)
org.apache.storm.task.TopologyContext.registerMetric(String, IReducer, int)
org.apache.storm.task.TopologyContext.registerMetric(String, T, int)
org.apache.storm.security.auth.ICredentialsRenewer.renew(Map<String, String>, Map)
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder.setBootstrapServers(String) Please use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with `ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG` instead
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder.setFetchMinBytes(int) Please use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with `ConsumerConfig.FETCH_MIN_BYTES_CONFIG` instead
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder.setGroupId(String) Please use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with `ConsumerConfig.GROUP_ID_CONFIG` instead
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder.setKey(Class<? extends Deserializer<NK>>) Please use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with `ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG` instead
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder.setKey(SerializableDeserializer<NK>) Please use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with `ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG` instead
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder.setMaxPartitionFectchBytes(int) Please use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with `ConsumerConfig.MAX_PARTITION_FETCH_BYTES_CONFIG` instead
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder.setMaxPollRecords(int) Please use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with `ConsumerConfig.MAX_POLL_RECORDS_CONFIG` instead
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder.setSecurityProtocol(String) Please use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with “security.protocol” instead
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder.setSSLKeystore(String, String) Please use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with “ssl.keystore.location” and “ssl.keystore.password” instead
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder.setSSLKeystore(String, String, String) Please use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with “ssl.keystore.location”, “ssl.keystore.password” and “ssl.key.password” instead
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder.setSSLTruststore(String, String) Please use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with “security.protocol”, “ssl.truststore.location” and “ssl.truststore.password” instead
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder.setValue(Class<? extends Deserializer<NV>>) Please use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with `ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG` instead
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder.setValue(SerializableDeserializer<NV>) Please use `KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object)` with `ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG` instead
org.apache.storm.utils.Time.startSimulating()
org.apache.storm.utils.Time.stopSimulating()

Deprecated Constructors
Constructor and Description
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder(String, Class<? extends Deserializer<K>>, Class<? extends Deserializer<V>>, Collection<String>) 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`
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder(String, Class<? extends Deserializer<K>>, Class<? extends Deserializer<V>>, Pattern) 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`
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder(String, Class<? extends Deserializer<K>>, Class<? extends Deserializer<V>>, String...) 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`
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder(String, Class<? extends Deserializer<K>>, Class<? extends Deserializer<V>>, Subscription) 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`
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder(String, SerializableDeserializer<K>, SerializableDeserializer<V>, Collection<String>) 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`
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder(String, SerializableDeserializer<K>, SerializableDeserializer<V>, Pattern) 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`
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder(String, SerializableDeserializer<K>, SerializableDeserializer<V>, String...) 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`
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder(String, SerializableDeserializer<K>, SerializableDeserializer<V>, Subscription) 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`
org.apache.storm.testing.FixedTupleSpout(List, String) please use `FixedTupleSpout.FixedTupleSpout(List, Fields)`

Deprecated API

Contents