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. 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 useBytesUtils.ByteArrayComparatorinstead.This field is not part of the public API and will be removed in version 5.0. Internal Kafka code should useBytesUtils.BYTES_LEXICO_COMPARATORinstead.This method is not part of the public API and will be removed in version 5.0. Internal Kafka code should useBytesUtils.increment(Bytes)instead.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.
-
Deprecated InterfacesInterfaceDescriptionThis interface is not part of the public API and will be removed in version 5.0. Internal Kafka code should use
BytesUtils.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
BytesUtils.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 useBytesUtils.increment(Bytes)instead.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.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.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.