Deprecated API
Contents
-
Terminally Deprecated ElementsElementDescriptionSince 4.1. Use
Admin.listConfigResources()instead.Since 4.1. UseAdmin.listConfigResources(Set, ListConfigResourcesOptions)instead.Since 4.1. UseAdmin.listGroups(ListGroupsOptions)instead.Since 4.1. UseAdmin.listGroups(ListGroupsOptions)instead.Since 4.0. UseConsumerGroupDescription.groupState()instead.Since 4.1. UseAdmin.listGroups(ListGroupsOptions)andGroupListinginstead.Since 4.1. UseRaftVoterEndpoint.listener()instead. This function will be removed in 5.0.Since 4.2, please useKafkaConsumer.groupMetadata()instead. This class will be an interface in Kafka 5.0.Since 4.2, please useKafkaConsumer.groupMetadata()instead. This class will be an interface in Kafka 5.0.Since 4.0. UseConsumerRecords(Map, Map)instead.Since 4.0. UseGroupStateinstead.Since 4.1. UseEndpoint.listener()instead. This function will be removed in 5.0.This interface is not part of the public API and will be removed in version 5.0. Internal Kafka code should useByteUtils.ByteArrayComparatorinstead.This field is not part of the public API and will be removed in version 5.0. Internal Kafka code should useByteUtils.BYTES_LEXICO_COMPARATORinstead.This method is not part of the public API and will be removed in version 5.0. Internal Kafka code should useByteUtils.increment(Bytes)instead.since 4.4 and should not be used any longer.Since 4.2.0, useClientTelemetryExporterProviderinstead. This interface will be removed in Kafka 5.0.0. The new interface provides aClientTelemetryExporterwhich includes additional context such as the push interval.Since 4.2.0, useClientTelemetryExporterinstead. 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.Since 4.4. UseStreamPartitioner.partitions(String, Object, Object, Headers, int)instead. This method is planned to be removed in 5.0.
-
Deprecated InterfacesInterfaceDescriptionThis interface is not part of the public API and will be removed in version 5.0. Internal Kafka code should use
ByteUtils.ByteArrayComparatorinstead.Since 4.2.0, useClientTelemetryExporterProviderinstead. This interface will be removed in Kafka 5.0.0. The new interface provides aClientTelemetryExporterwhich includes additional context such as the push interval.Since 4.2.0, useClientTelemetryExporterinstead. 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.Since 4.0. Useapi.Processorinstead.Since 4.0. Useapi.ProcessorSupplierinstead.Since 4.0. UseFixedKeyProcessorinstead.Since 4.0. UseFixedKeyProcessorSupplierinstead.
-
Deprecated ClassesClassDescriptionSince 4.1. Use
Admin.listGroups(ListGroupsOptions)andGroupListinginstead.Since 4.1. UseListConfigResourcesOptionsinstead.Since 4.1. UseListConfigResourcesResultinstead.Since 4.1. UseAdmin.listGroups(ListGroupsOptions)instead.Since 4.1. UseAdmin.listGroups(ListGroupsOptions)instead.Since 4.0 and should not be used any longer.Since 4.0. UseMockProcessorContextinstead.
-
Deprecated Enum ClassesEnum ClassDescriptionsince 4.0; will be removed in a future release. Not required by Kafka client users; no replacement is provided.Since 4.0. Use
GroupStateinstead.Since 4.0. UseAutoOffsetResetinstead.
-
Deprecated Exception ClassesException ClassDescriptionsince 4.2 and should not be used any longer.
-
Deprecated FieldsFieldDescriptiondown-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.This field is not part of the public API and will be removed in version 5.0. Internal Kafka code should use
ByteUtils.BYTES_LEXICO_COMPARATORinstead.Since 3.4. Use"statestore.cache.max.bytes"instead.Since 4.0. UseStreamsConfig.DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIGinstead.Since 3.7. UseStreamsConfig.DSL_STORE_SUPPLIERS_CLASS_CONFIGinstead.Since 4.0. UseStreamsConfig.PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIGinstead.Since 4.3. Default will change totruewhen removed.since 4.1.0. UseTimeWindowedDeserializer.WINDOW_SIZE_MS_CONFIGforTimeWindowedDeserializer.since 4.1.0. UseTimeWindowedSerializer.WINDOWED_INNER_SERIALIZER_CLASSforTimeWindowedSerializer. UseTimeWindowedDeserializer.WINDOWED_INNER_DESERIALIZER_CLASSforTimeWindowedDeserializer. UseSessionWindowedSerializer.WINDOWED_INNER_SERIALIZER_CLASSforSessionWindowedSerializer. UseSessionWindowedDeserializer.WINDOWED_INNER_DESERIALIZER_CLASSforSessionWindowedDeserializer.
-
Deprecated MethodsMethodDescriptionSince 4.1. Use
Admin.listConfigResources()instead.Since 4.1. UseAdmin.listConfigResources(Set, ListConfigResourcesOptions)instead.Since 4.1. UseAdmin.listGroups(ListGroupsOptions)instead.Since 4.1. UseAdmin.listGroups(ListGroupsOptions)instead.Since 4.0. UseConsumerGroupDescription.groupState()instead.Since 4.0. UseConsumerGroupListing.groupState()instead.Since 4.0 and should not be used any longer.Since 4.0 and should not be used any longer.Since 4.0. UseListConsumerGroupsOptions.inGroupStates(Set)instead.Since 4.0. UseListConsumerGroupsOptions.inGroupStates(Set)instead.Since 4.1. UseRaftVoterEndpoint.listener()instead. This function will be removed in 5.0.Since 4.1. UseEndpoint.listener()instead. This function will be removed in 5.0.This method is not part of the public API and will be removed in version 5.0. Internal Kafka code should useByteUtils.increment(Bytes)instead.since 4.4 and should not be used any longer.Since 3.9. UseDeserializationExceptionHandler.handle(ErrorHandlerContext, ConsumerRecord, Exception)instead.Since 3.9. UseProductionExceptionHandler.handle(ErrorHandlerContext, ProducerRecord, Exception)instead.Since 4.0. UseConsumed.with(Serde, Serde, TimestampExtractor, AutoOffsetReset)instead.Since 4.0. UseConsumed.with(AutoOffsetReset)instead.Since 4.0. UseConsumed.withOffsetResetPolicy(AutoOffsetReset)instead.Since 4.0 and should not be used any longer.Since 4.0 and should not be used any longer.Since 4.0 and should not be used any longer.Since 4.0 and should not be used any longer.Since 3.0. UseJoinWindows.ofTimeDifferenceAndGrace(Duration, Duration)instead.Since 3.0. UseJoinWindows.ofTimeDifferenceWithNoGrace(Duration)instead.Since 4.4. UseKStream.join(GlobalKTable, KeyValueMapper, ValueJoinerWithStreamAndMappedKey)instead.Since 4.4. UseKStream.join(GlobalKTable, KeyValueMapper, ValueJoinerWithStreamAndMappedKey, Named)instead.Since 4.4. UseKStream.leftJoin(GlobalKTable, KeyValueMapper, ValueJoinerWithStreamAndMappedKey)instead.Since 4.4. UseKStream.leftJoin(GlobalKTable, KeyValueMapper, ValueJoinerWithStreamAndMappedKey, Named)instead.UseProcessorContext#commit()instead.New implementations should always returntrueand manage their own offsets. In the future, this method will be removed and it will be assumed to always returntrue.Since 4.4. UseStreamPartitioner.partitions(String, Object, Object, Headers, int)instead. This method is planned to be removed in 5.0.Since 4.3. UseDslKeyValueParams.dslStoreFormat()instead to check the store format.Since 4.3. UseDslWindowParams.dslStoreFormat()instead to check the store format.Since 4.3. UseStateSerdes.keyFrom(byte[], Headers)instead.Since 4.3. UseStateSerdes.rawKey(Object, Headers)instead.Since 4.3. UseStateSerdes.rawValue(Object, Headers)instead.Since 4.3. UseStateSerdes.valueFrom(byte[], Headers)instead.Since 4.0. UseStreamsConfig.deserializationExceptionHandler()instead.Since 4.0. UseStreamsConfig.productionExceptionHandler()instead.Since 4.0. UseTopology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, String...)instead.Since 4.0. UseTopology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, Pattern)instead.
-
Deprecated ConstructorsConstructorDescriptionSince 4.0. Use
ConsumerGroupListing(String, Optional, boolean)instead.Since 4.0. UseConsumerGroupListing(String, Optional, Optional, boolean)instead.Since 4.2, please useKafkaConsumer.groupMetadata()instead. This class will be an interface in Kafka 5.0.Since 4.2, please useKafkaConsumer.groupMetadata()instead. This class will be an interface in Kafka 5.0.Since 4.0. UseConsumerRecords(Map, Map)instead.Since 4.0. UseMockConsumer(String)instead.Since 4.3. UseDslKeyValueParams(String, DslStoreFormat)instead.Since 4.3. UseDslWindowParams(String, Duration, Duration, boolean, EmitStrategy, boolean, DslStoreFormat)Params(String, DslStoreFormat)} instead.