Skip navigation links
  • Overview
  • Package
  • Class
  • Tree
  • Deprecated
  • Index
  • Help

Deprecated API

Contents

  • Terminally Deprecated
  • Interfaces
  • Classes
  • Enum Classes
  • Exceptions
  • Fields
  • Methods
  • Constructors
  • Terminally Deprecated Elements
    Element
    Description
    org.apache.kafka.clients.admin.Admin.listClientMetricsResources()
    Since 4.1. Use Admin.listConfigResources() instead.
    org.apache.kafka.clients.admin.Admin.listClientMetricsResources(ListClientMetricsResourcesOptions)
    Since 4.1. Use Admin.listConfigResources(Set, ListConfigResourcesOptions) instead.
    org.apache.kafka.clients.admin.Admin.listConsumerGroups()
    Since 4.1. Use Admin.listGroups(ListGroupsOptions) instead.
    org.apache.kafka.clients.admin.Admin.listConsumerGroups(ListConsumerGroupsOptions)
    Since 4.1. Use Admin.listGroups(ListGroupsOptions) instead.
    org.apache.kafka.clients.admin.ConsumerGroupDescription(String, boolean, Collection<MemberDescription>, String, ConsumerGroupState, Node)
    Since 4.0. Use ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional) instead.
    org.apache.kafka.clients.admin.ConsumerGroupDescription(String, boolean, Collection<MemberDescription>, String, ConsumerGroupState, Node, Set<AclOperation>)
    Since 4.0. Use ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional) instead.
    org.apache.kafka.clients.admin.ConsumerGroupDescription(String, boolean, Collection<MemberDescription>, String, GroupType, ConsumerGroupState, Node, Set<AclOperation>)
    Since 4.0. Use ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional) instead.
    org.apache.kafka.clients.admin.ConsumerGroupDescription.state()
    Since 4.0. Use ConsumerGroupDescription.groupState() instead.
    org.apache.kafka.clients.admin.ConsumerGroupListing
    Since 4.1. Use Admin.listGroups(ListGroupsOptions) and GroupListing instead.
    org.apache.kafka.clients.admin.KafkaAdminClient.listConsumerGroups(ListConsumerGroupsOptions)
    org.apache.kafka.clients.admin.MemberDescription(String, String, String, MemberAssignment)
    Since 4.0. Use MemberDescription(String, Optional, Optional, String, String, MemberAssignment, Optional, Optional, Optional) instead.
    org.apache.kafka.clients.admin.MemberDescription(String, Optional<String>, String, String, MemberAssignment)
    Since 4.0. Use MemberDescription(String, Optional, Optional, String, String, MemberAssignment, Optional, Optional, Optional) instead.
    org.apache.kafka.clients.admin.MemberDescription(String, Optional<String>, String, String, MemberAssignment, Optional<MemberAssignment>)
    Since 4.0. Use MemberDescription(String, Optional, Optional, String, String, MemberAssignment, Optional, Optional, Optional) instead.
    org.apache.kafka.clients.admin.MemberDescription(String, Optional<String>, String, String, MemberAssignment, Optional<MemberAssignment>, Optional<Integer>, Optional<Boolean>)
    Since 4.2. Use MemberDescription(String, Optional, Optional, String, String, MemberAssignment, Optional, Optional, Optional) instead.
    org.apache.kafka.clients.admin.RaftVoterEndpoint.name()
    Since 4.1. Use RaftVoterEndpoint.listener() instead. This function will be removed in 5.0.
    org.apache.kafka.clients.consumer.ConsumerGroupMetadata(String)
    Since 4.2, please use KafkaConsumer.groupMetadata() instead. This class will be an interface in Kafka 5.0.
    org.apache.kafka.clients.consumer.ConsumerGroupMetadata(String, int, String, Optional<String>)
    Since 4.2, please use KafkaConsumer.groupMetadata() instead. This class will be an interface in Kafka 5.0.
    org.apache.kafka.common.ConsumerGroupState
    Since 4.0. Use GroupState instead.
    org.apache.kafka.common.Endpoint.listenerName()
    Since 4.1. Use Endpoint.listener() instead. This function will be removed in 5.0.
    org.apache.kafka.common.utils.Bytes.ByteArrayComparator
    This interface is not part of the public API and will be removed in version 5.0. Internal Kafka code should use BytesUtils.ByteArrayComparator instead.
    org.apache.kafka.common.utils.Bytes.BYTES_LEXICO_COMPARATOR
    This field is not part of the public API and will be removed in version 5.0. Internal Kafka code should use BytesUtils.BYTES_LEXICO_COMPARATOR instead.
    org.apache.kafka.common.utils.Bytes.increment(Bytes)
    This method is not part of the public API and will be removed in version 5.0. Internal Kafka code should use BytesUtils.increment(Bytes) instead.
    org.apache.kafka.server.telemetry.ClientTelemetry
    Since 4.2.0, use ClientTelemetryExporterProvider instead. This interface will be removed in Kafka 5.0.0. The new interface provides a ClientTelemetryExporter which includes additional context such as the push interval.
    org.apache.kafka.server.telemetry.ClientTelemetryReceiver
    Since 4.2.0, use ClientTelemetryExporter instead. This interface will be removed in Kafka 5.0.0. The new interface provides additional context including the push interval to enable better metric lifecycle management.
  • Deprecated Interfaces
    Interface
    Description
    org.apache.kafka.common.utils.Bytes.ByteArrayComparator
    This interface is not part of the public API and will be removed in version 5.0. Internal Kafka code should use BytesUtils.ByteArrayComparator instead.
    org.apache.kafka.server.telemetry.ClientTelemetry
    Since 4.2.0, use ClientTelemetryExporterProvider instead. This interface will be removed in Kafka 5.0.0. The new interface provides a ClientTelemetryExporter which includes additional context such as the push interval.
    org.apache.kafka.server.telemetry.ClientTelemetryReceiver
    Since 4.2.0, use ClientTelemetryExporter instead. This interface will be removed in Kafka 5.0.0. The new interface provides additional context including the push interval to enable better metric lifecycle management.
    org.apache.kafka.streams.kstream.Transformer
    Since 4.0. Use api.Processor instead.
    org.apache.kafka.streams.kstream.TransformerSupplier
    Since 4.0. Use api.ProcessorSupplier instead.
    org.apache.kafka.streams.kstream.ValueTransformer
    Since 4.0. Use FixedKeyProcessor instead.
    org.apache.kafka.streams.kstream.ValueTransformerSupplier
    Since 4.0. Use FixedKeyProcessorSupplier instead.
  • Deprecated Classes
    Class
    Description
    org.apache.kafka.clients.admin.ClientMetricsResourceListing
    org.apache.kafka.clients.admin.ConsumerGroupListing
    Since 4.1. Use Admin.listGroups(ListGroupsOptions) and GroupListing instead.
    org.apache.kafka.clients.admin.ListClientMetricsResourcesOptions
    Since 4.1. Use ListConfigResourcesOptions instead.
    org.apache.kafka.clients.admin.ListClientMetricsResourcesResult
    Since 4.1. Use ListConfigResourcesResult instead.
    org.apache.kafka.clients.admin.ListConsumerGroupsOptions
    Since 4.1. Use Admin.listGroups(ListGroupsOptions) instead.
    org.apache.kafka.clients.admin.ListConsumerGroupsResult
    Since 4.1. Use Admin.listGroups(ListGroupsOptions) instead.
    org.apache.kafka.streams.KafkaStreams.CloseOptions
    org.apache.kafka.streams.kstream.ForeachProcessor
    Since 4.0 and should not be used any longer.
    org.apache.kafka.streams.processor.MockProcessorContext
    Since 4.0. Use MockProcessorContext instead.
  • Deprecated Enum Classes
    Enum Class
    Description
    org.apache.kafka.clients.consumer.OffsetResetStrategy
    since 4.0; will be removed in a future release. Not required by Kafka client users; no replacement is provided.
    org.apache.kafka.common.ConsumerGroupState
    Since 4.0. Use GroupState instead.
    org.apache.kafka.streams.errors.DeserializationExceptionHandler.DeserializationHandlerResponse
    org.apache.kafka.streams.errors.ProcessingExceptionHandler.ProcessingHandlerResponse
    org.apache.kafka.streams.errors.ProductionExceptionHandler.ProductionExceptionHandlerResponse
    org.apache.kafka.streams.Topology.AutoOffsetReset
    Since 4.0. Use AutoOffsetReset instead.
  • Deprecated Exceptions
    Exceptions
    Description
    org.apache.kafka.streams.errors.BrokerNotFoundException
    since 4.2 and should not be used any longer.
  • Deprecated Fields
    Field
    Description
    org.apache.kafka.clients.producer.ProducerConfig.PARTITIONER_ADPATIVE_PARTITIONING_ENABLE_CONFIG
    org.apache.kafka.common.config.TopicConfig.MESSAGE_DOWNCONVERSION_ENABLE_CONFIG
    down-conversion is not possible in Apache Kafka 4.0 and newer, hence this configuration is a no-op, and it is deprecated for removal in Apache Kafka 5.0.
    org.apache.kafka.common.config.TopicConfig.MESSAGE_DOWNCONVERSION_ENABLE_DOC
    see TopicConfig.MESSAGE_DOWNCONVERSION_ENABLE_CONFIG.
    org.apache.kafka.common.utils.Bytes.BYTES_LEXICO_COMPARATOR
    This field is not part of the public API and will be removed in version 5.0. Internal Kafka code should use BytesUtils.BYTES_LEXICO_COMPARATOR instead.
    org.apache.kafka.server.log.remote.storage.RemoteStorageMetrics.DEPRECATE_REMOTE_LOG_READER_AVG_IDLE_PERCENT_METRIC
    org.apache.kafka.server.log.remote.storage.RemoteStorageMetrics.DEPRECATE_REMOTE_LOG_READER_TASK_QUEUE_SIZE_METRIC
    org.apache.kafka.streams.StreamsConfig.BUFFERED_RECORDS_PER_PARTITION_DOC
    org.apache.kafka.streams.StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG
    Since 3.4. Use "statestore.cache.max.bytes" instead.
    org.apache.kafka.streams.StreamsConfig.CACHE_MAX_BYTES_BUFFERING_DOC
    org.apache.kafka.streams.StreamsConfig.DEFAULT_CLIENT_SUPPLIER_DOC
    org.apache.kafka.streams.StreamsConfig.DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG
    Since 4.0. Use StreamsConfig.DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG instead.
    org.apache.kafka.streams.StreamsConfig.DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_DOC
    org.apache.kafka.streams.StreamsConfig.DEFAULT_DSL_STORE
    org.apache.kafka.streams.StreamsConfig.DEFAULT_DSL_STORE_CONFIG
    Since 3.7. Use StreamsConfig.DSL_STORE_SUPPLIERS_CLASS_CONFIG instead.
    org.apache.kafka.streams.StreamsConfig.DEFAULT_DSL_STORE_DOC
    org.apache.kafka.streams.StreamsConfig.DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG
    Since 4.0. Use StreamsConfig.PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG instead.
    org.apache.kafka.streams.StreamsConfig.DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_DOC
    org.apache.kafka.streams.StreamsConfig.DUMMY_THREAD_INDEX
    org.apache.kafka.streams.StreamsConfig.ENABLE_METRICS_PUSH_DOC
    org.apache.kafka.streams.StreamsConfig.IN_MEMORY
    org.apache.kafka.streams.StreamsConfig.InternalConfig.TOPIC_PREFIX_ALTERNATIVE
    org.apache.kafka.streams.StreamsConfig.MAX_TASK_IDLE_MS_DOC
    org.apache.kafka.streams.StreamsConfig.PROCESSING_EXCEPTION_HANDLER_CLASS_DOC
    org.apache.kafka.streams.StreamsConfig.PROCESSING_EXCEPTION_HANDLER_GLOBAL_ENABLED_CONFIG
    Since 4.3. Default will change to true when removed.
    org.apache.kafka.streams.StreamsConfig.RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_DOC
    org.apache.kafka.streams.StreamsConfig.RACK_AWARE_ASSIGNMENT_STRATEGY_DOC
    org.apache.kafka.streams.StreamsConfig.RACK_AWARE_ASSIGNMENT_TRAFFIC_COST_DOC
    org.apache.kafka.streams.StreamsConfig.ROCKS_DB
    org.apache.kafka.streams.StreamsConfig.STATESTORE_CACHE_MAX_BYTES_DOC
    org.apache.kafka.streams.StreamsConfig.TASK_TIMEOUT_MS_DOC
    org.apache.kafka.streams.StreamsConfig.WINDOW_SIZE_MS_CONFIG
    since 4.1.0. Use TimeWindowedDeserializer.WINDOW_SIZE_MS_CONFIG for TimeWindowedDeserializer.
    org.apache.kafka.streams.StreamsConfig.WINDOWED_INNER_CLASS_SERDE
    since 4.1.0. Use TimeWindowedSerializer.WINDOWED_INNER_SERIALIZER_CLASS for TimeWindowedSerializer. Use TimeWindowedDeserializer.WINDOWED_INNER_DESERIALIZER_CLASS for TimeWindowedDeserializer. Use SessionWindowedSerializer.WINDOWED_INNER_SERIALIZER_CLASS for SessionWindowedSerializer. Use SessionWindowedDeserializer.WINDOWED_INNER_DESERIALIZER_CLASS for SessionWindowedDeserializer.
  • Deprecated Methods
    Method
    Description
    org.apache.kafka.clients.admin.Admin.listClientMetricsResources()
    Since 4.1. Use Admin.listConfigResources() instead.
    org.apache.kafka.clients.admin.Admin.listClientMetricsResources(ListClientMetricsResourcesOptions)
    Since 4.1. Use Admin.listConfigResources(Set, ListConfigResourcesOptions) instead.
    org.apache.kafka.clients.admin.Admin.listConsumerGroups()
    Since 4.1. Use Admin.listGroups(ListGroupsOptions) instead.
    org.apache.kafka.clients.admin.Admin.listConsumerGroups(ListConsumerGroupsOptions)
    Since 4.1. Use Admin.listGroups(ListGroupsOptions) instead.
    org.apache.kafka.clients.admin.ConsumerGroupDescription.state()
    Since 4.0. Use ConsumerGroupDescription.groupState() instead.
    org.apache.kafka.clients.admin.ConsumerGroupListing.state()
    Since 4.0. Use ConsumerGroupListing.groupState() instead.
    org.apache.kafka.clients.admin.CreateDelegationTokenOptions.maxlifeTimeMs()
    Since 4.0 and should not be used any longer.
    org.apache.kafka.clients.admin.CreateDelegationTokenOptions.maxlifeTimeMs(long)
    Since 4.0 and should not be used any longer.
    org.apache.kafka.clients.admin.ForwardingAdmin.listConsumerGroups(ListConsumerGroupsOptions)
    org.apache.kafka.clients.admin.KafkaAdminClient.listConsumerGroups(ListConsumerGroupsOptions)
    org.apache.kafka.clients.admin.ListConsumerGroupsOptions.inStates(Set<ConsumerGroupState>)
    Since 4.0. Use ListConsumerGroupsOptions.inGroupStates(Set) instead.
    org.apache.kafka.clients.admin.ListConsumerGroupsOptions.states()
    Since 4.0. Use ListConsumerGroupsOptions.inGroupStates(Set) instead.
    org.apache.kafka.clients.admin.RaftVoterEndpoint.name()
    Since 4.1. Use RaftVoterEndpoint.listener() instead. This function will be removed in 5.0.
    org.apache.kafka.clients.consumer.Consumer.close(Duration)
    org.apache.kafka.clients.consumer.KafkaConsumer.close(Duration)
    org.apache.kafka.clients.consumer.MockConsumer.close(Duration)
    org.apache.kafka.common.Endpoint.listenerName()
    Since 4.1. Use Endpoint.listener() instead. This function will be removed in 5.0.
    org.apache.kafka.common.utils.Bytes.increment(Bytes)
    This method is not part of the public API and will be removed in version 5.0. Internal Kafka code should use BytesUtils.increment(Bytes) instead.
    org.apache.kafka.streams.errors.DeserializationExceptionHandler.handle(ErrorHandlerContext, ConsumerRecord<byte[], byte[]>, Exception)
    Use DeserializationExceptionHandler.handleError(ErrorHandlerContext, ConsumerRecord, Exception) instead.
    org.apache.kafka.streams.errors.DeserializationExceptionHandler.handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception)
    Since 3.9. Use DeserializationExceptionHandler.handle(ErrorHandlerContext, ConsumerRecord, Exception) instead.
    org.apache.kafka.streams.errors.ProcessingExceptionHandler.handle(ErrorHandlerContext, Record<?, ?>, Exception)
    Use ProcessingExceptionHandler.handleError(ErrorHandlerContext, Record, Exception) instead.
    org.apache.kafka.streams.errors.ProductionExceptionHandler.handle(ProducerRecord<byte[], byte[]>, Exception)
    Since 3.9. Use ProductionExceptionHandler.handle(ErrorHandlerContext, ProducerRecord, Exception) instead.
    org.apache.kafka.streams.errors.ProductionExceptionHandler.handle(ErrorHandlerContext, ProducerRecord<byte[], byte[]>, Exception)
    Use ProductionExceptionHandler.handleError(ErrorHandlerContext, ProducerRecord, Exception) instead.
    org.apache.kafka.streams.errors.ProductionExceptionHandler.handleSerializationException(ProducerRecord, Exception)
    Since 3.9. Use ProductionExceptionHandler.handleSerializationException(ErrorHandlerContext, ProducerRecord, Exception, SerializationExceptionOrigin) instead.
    org.apache.kafka.streams.errors.ProductionExceptionHandler.handleSerializationException(ErrorHandlerContext, ProducerRecord, Exception, ProductionExceptionHandler.SerializationExceptionOrigin)
    Use ProductionExceptionHandler.handleSerializationError(ErrorHandlerContext, ProducerRecord, Exception, SerializationExceptionOrigin) instead.
    org.apache.kafka.streams.KafkaStreams.close(KafkaStreams.CloseOptions)
    org.apache.kafka.streams.KafkaStreams.CloseOptions.leaveGroup(boolean)
    org.apache.kafka.streams.KafkaStreams.CloseOptions.timeout(Duration)
    org.apache.kafka.streams.kstream.Consumed.with(Serde<K>, Serde<V>, TimestampExtractor, Topology.AutoOffsetReset)
    Since 4.0. Use Consumed.with(Serde, Serde, TimestampExtractor, AutoOffsetReset) instead.
    org.apache.kafka.streams.kstream.Consumed.with(Topology.AutoOffsetReset)
    Since 4.0. Use Consumed.with(AutoOffsetReset) instead.
    org.apache.kafka.streams.kstream.Consumed.withOffsetResetPolicy(Topology.AutoOffsetReset)
    Since 4.0. Use Consumed.withOffsetResetPolicy(AutoOffsetReset) instead.
    org.apache.kafka.streams.kstream.Joined.gracePeriod()
    Since 4.0 and should not be used any longer.
    org.apache.kafka.streams.kstream.Joined.keySerde()
    Since 4.0 and should not be used any longer.
    org.apache.kafka.streams.kstream.Joined.otherValueSerde()
    Since 4.0 and should not be used any longer.
    org.apache.kafka.streams.kstream.Joined.valueSerde()
    Since 4.0 and should not be used any longer.
    org.apache.kafka.streams.kstream.JoinWindows.grace(Duration)
    Since 3.0. Use JoinWindows.ofTimeDifferenceAndGrace(Duration, Duration) instead.
    org.apache.kafka.streams.kstream.JoinWindows.of(Duration)
    Since 3.0. Use JoinWindows.ofTimeDifferenceWithNoGrace(Duration)} instead.
    org.apache.kafka.streams.processor.StateStore.flush()
    Use ProcessorContext#commit() instead.
    org.apache.kafka.streams.processor.StateStore.managesOffsets()
    New implementations should always return true and manage their own offsets. In the future, this method will be removed and it will be assumed to always return true.
    org.apache.kafka.streams.state.DslKeyValueParams.isTimestamped()
    Since 4.3. Use DslKeyValueParams.dslStoreFormat() instead to check the store format.
    org.apache.kafka.streams.state.DslWindowParams.isTimestamped()
    Since 4.3. Use DslWindowParams.dslStoreFormat() instead to check the store format.
    org.apache.kafka.streams.state.StateSerdes.keyFrom(byte[])
    Since 4.3. Use StateSerdes.keyFrom(byte[], Headers) instead.
    org.apache.kafka.streams.state.StateSerdes.rawKey(K)
    Since 4.3. Use StateSerdes.rawKey(Object, Headers) instead.
    org.apache.kafka.streams.state.StateSerdes.rawValue(V)
    Since 4.3. Use StateSerdes.rawValue(Object, Headers) instead.
    org.apache.kafka.streams.state.StateSerdes.valueFrom(byte[])
    Since 4.3. Use StateSerdes.valueFrom(byte[], Headers) instead.
    org.apache.kafka.streams.StreamsConfig.defaultDeserializationExceptionHandler()
    Since 4.0. Use StreamsConfig.deserializationExceptionHandler() instead.
    org.apache.kafka.streams.StreamsConfig.defaultProductionExceptionHandler()
    Since 4.0. Use StreamsConfig.productionExceptionHandler() instead.
    org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, String, String...)
    Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, String...) instead.
    org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, String, Pattern)
    Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, Pattern) instead.
    org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, String, Deserializer<K>, Deserializer<V>, String...)
    Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, Deserializer, Deserializer, String...) instead.
    org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, String, Deserializer<K>, Deserializer<V>, Pattern)
    Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, Deserializer, Deserializer, Pattern) instead.
    org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, String, TimestampExtractor, Deserializer<K>, Deserializer<V>, String...)
    Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, TimestampExtractor, Deserializer, Deserializer, String...) instead.
    org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, String, TimestampExtractor, Deserializer<K>, Deserializer<V>, Pattern)
    Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, TimestampExtractor, Deserializer, Deserializer, Pattern) instead.
    org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, TimestampExtractor, String, String...)
    Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, TimestampExtractor, String, String...) instead.
    org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, TimestampExtractor, String, Pattern)
    Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, TimestampExtractor, String, Pattern) instead.
    org.apache.kafka.streams.TopologyConfig.parseStoreType()
  • Deprecated Constructors
    Constructor
    Description
    org.apache.kafka.clients.admin.ConsumerGroupDescription(String, boolean, Collection<MemberDescription>, String, ConsumerGroupState, Node)
    Since 4.0. Use ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional) instead.
    org.apache.kafka.clients.admin.ConsumerGroupDescription(String, boolean, Collection<MemberDescription>, String, ConsumerGroupState, Node, Set<AclOperation>)
    Since 4.0. Use ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional) instead.
    org.apache.kafka.clients.admin.ConsumerGroupDescription(String, boolean, Collection<MemberDescription>, String, GroupType, ConsumerGroupState, Node, Set<AclOperation>)
    Since 4.0. Use ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional) instead.
    org.apache.kafka.clients.admin.ConsumerGroupListing(String, boolean, Optional<ConsumerGroupState>)
    Since 4.0. Use ConsumerGroupListing(String, Optional, boolean) instead.
    org.apache.kafka.clients.admin.ConsumerGroupListing(String, boolean, Optional<ConsumerGroupState>, Optional<GroupType>)
    Since 4.0. Use ConsumerGroupListing(String, Optional, Optional, boolean) instead.
    org.apache.kafka.clients.admin.MemberDescription(String, String, String, MemberAssignment)
    Since 4.0. Use MemberDescription(String, Optional, Optional, String, String, MemberAssignment, Optional, Optional, Optional) instead.
    org.apache.kafka.clients.admin.MemberDescription(String, Optional<String>, String, String, MemberAssignment)
    Since 4.0. Use MemberDescription(String, Optional, Optional, String, String, MemberAssignment, Optional, Optional, Optional) instead.
    org.apache.kafka.clients.admin.MemberDescription(String, Optional<String>, String, String, MemberAssignment, Optional<MemberAssignment>)
    Since 4.0. Use MemberDescription(String, Optional, Optional, String, String, MemberAssignment, Optional, Optional, Optional) instead.
    org.apache.kafka.clients.admin.MemberDescription(String, Optional<String>, String, String, MemberAssignment, Optional<MemberAssignment>, Optional<Integer>, Optional<Boolean>)
    Since 4.2. Use MemberDescription(String, Optional, Optional, String, String, MemberAssignment, Optional, Optional, Optional) instead.
    org.apache.kafka.clients.consumer.ConsumerGroupMetadata(String)
    Since 4.2, please use KafkaConsumer.groupMetadata() instead. This class will be an interface in Kafka 5.0.
    org.apache.kafka.clients.consumer.ConsumerGroupMetadata(String, int, String, Optional<String>)
    Since 4.2, please use KafkaConsumer.groupMetadata() instead. This class will be an interface in Kafka 5.0.
    org.apache.kafka.clients.consumer.ConsumerRecords(Map<TopicPartition, List<ConsumerRecord<K, V>>>)
    Since 4.0. Use ConsumerRecords(Map, Map) instead.
    org.apache.kafka.clients.consumer.MockConsumer(OffsetResetStrategy)
    Since 4.0. Use MockConsumer(String) instead.
    org.apache.kafka.common.errors.RecordDeserializationException(TopicPartition, long, String, Throwable)
    Since 3.9. Use RecordDeserializationException(DeserializationExceptionOrigin, TopicPartition, long, long, TimestampType, ByteBuffer, ByteBuffer, Headers, String, Throwable) instead.
    org.apache.kafka.streams.state.DslKeyValueParams(String, boolean)
    Since 4.3. Use DslKeyValueParams(String, DslStoreFormat) instead.
    org.apache.kafka.streams.state.DslSessionParams(String, Duration, EmitStrategy)
    org.apache.kafka.streams.state.DslWindowParams(String, Duration, Duration, boolean, EmitStrategy, boolean, boolean)
    Since 4.3. Use DslWindowParams(String, Duration, Duration, boolean, EmitStrategy, boolean, DslStoreFormat) Params(String, DslStoreFormat)} instead.