Deprecated API

Contents

• Enum Classes
• Fields
• Methods
• Constructors
• Enum Constants

• 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.

• Deprecated Fields

  Field

  Description

  org.apache.kafka.common.config.ConfluentTopicConfig.CONTEXT_NAME_CONFIG

  This config is deprecated and will be removed from 9.0 versions.

  org.apache.kafka.common.config.ConfluentTopicConfig.CONTEXT_NAME_DOC

  This config is deprecated and will be removed from 9.0 versions.

  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.

• Deprecated Methods

  Method

  Description

  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.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.MirrorTopicDescription.linkId()

  org.apache.kafka.clients.admin.MirrorTopicDescription.mirrorTopic()

  org.apache.kafka.clients.admin.NewMirrorTopic.mirrorTopic()

  This method is being deprecated because mirrorTopic is not an accurate name to describe a method that returns the source topic's name.

  Use NewMirrorTopic.sourceTopic()} instead.

• Deprecated Constructors

  Constructor

  Description

  org.apache.kafka.clients.admin.BrokerRemovalDescription(Integer, BalancerOperationStatus, BrokerShutdownStatus, PartitionReassignmentsStatus, Optional<BrokerRemovalError>, long, long)

  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.EvenClusterLoadPlanGoalStatsResources(double, double, double, double, double, double, int, int, int)

  since 7.5.0; prefer the other constructor EvenClusterLoadPlanGoalStatsResources(double, double, double, double, double, double, int, int, int) since it includes the consumerOutboundKBps

  org.apache.kafka.clients.admin.EvenClusterLoadPlanGoalStatsResources(double, double, double, double, double, int, int, int)

  since 7.4.0; prefer the other constructor EvenClusterLoadPlanGoalStatsResources(double, double, double, double, double, double, int, int, int) since it includes the producerInboundKBps

  org.apache.kafka.clients.admin.MemberDescription(String, String, String, MemberAssignment)

  Since 4.0. Use MemberDescription(String, 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, 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, String, String, MemberAssignment, Optional, Optional, Optional) instead.

  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.

• Deprecated Enum Constants

  Enum Constant

  Description

  org.apache.kafka.clients.admin.EvenClusterLoadStatus.DISABLED

  since 7.3.0