Deprecated API

Contents

• Deprecated Classes
• Deprecated Fields
• Deprecated Methods

Deprecated Classes

Class and Description
org.apache.storm.serialization.DefaultSerializationDelegate
org.apache.storm.serialization.GzipBridgeSerializationDelegate
org.apache.storm.kafka.bolt.KafkaBolt Please use the KafkaBolt in storm-kafka-client
org.apache.storm.drpc.LinearDRPCTopologyBuilder
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

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.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.tuple.TupleImpl.getSourceGlobalStreamid()
org.apache.storm.tuple.Tuple.getSourceGlobalStreamid() replaced by Tuple.getSourceGlobalStreamId() due to broken naming convention
org.apache.storm.security.INimbusCredentialPlugin.populateCredentials(Map<String, String>, Map)
org.apache.storm.security.auth.ICredentialsRenewer.renew(Map<String, String>, Map)
org.apache.storm.utils.Time.startSimulating()
org.apache.storm.utils.Time.stopSimulating()