-
Deprecated Interfaces
-
Deprecated ClassesClassDescriptionSince 3.3.0, in order to use default partitioning logic remove the
partitioner.classconfiguration setting and setpartitioner.ignore.keys=true. See KIP-794 for more info. The partitioning strategy:- If a partition is specified in the record, use it
- Otherwise choose the sticky partition that changes when the batch is full. NOTE: In contrast to the DefaultPartitioner, the record key is NOT used as part of the partitioning strategy in this partitioner. Records with the same key are not guaranteed to be sent to the same partition. See KIP-480 for details about sticky partitioning.
Since Kafka 3.0. Use theKafkaFuture.BaseFunctionfunctional interface.See org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginCallbackHandlerSee org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallbackHandlerSince 3.0. UseProcessororContextualProcessorinstead.since 3.0, useTaskMetadatainstead.since 3.0 useThreadMetadatainsteadsince 3.0.0 useStreamsMetadata
-
Deprecated Exceptions
-
Deprecated FieldsFieldDescriptionchecksums are no longer exposed by this class, this constant will be removed in Apache Kafka 4.0 (deprecated since 3.0).since 3.0, removal planned in 4.0. The default value for this config is appropriate for most situations.since 3.0, removal planned in 4.0. The default value for this config is appropriate for most situations.since 3.6, removal planned in 4.0. Use message.timestamp.before.max.ms and message.timestamp.after.max.ms insteadsince 3.6, removal planned in 4.0. Use message.timestamp.before.max.ms and message.timestamp.after.max.ms insteadand will be removed in 4.0.0since 3.4.0 Use
"statestore.cache.max.bytes"instead.since 3.0.0 Use"windowed.inner.class.serde"instead.since 3.0.0 Use"windowed.inner.class.serde"instead.since 3.0.0, will be removed in 4.0. Use"exactly_once_v2"instead.since 3.0.0, will be removed in 4.0. Use"exactly_once_v2"instead.since 2.7since 2.7; useStreamsConfig.TOPOLOGY_OPTIMIZATION_CONFIGinstead
-
Deprecated MethodsMethodDescriptionSince 2.3. Use
Admin.incrementalAlterConfigs(Map).Since 2.3. UseAdmin.incrementalAlterConfigs(Map, AlterConfigsOptions).Since 3.0 useDeleteTopicsResult.topicNameValues()insteadDeprecated Since Kafka 2.7. UseDescribeLogDirsResult.allDescriptions().Deprecated Since Kafka 2.7. UseDescribeLogDirsResult.descriptions().Since 3.1.0 useDescribeTopicsResult.allTopicNames()insteadSince 3.1.0 useDescribeTopicsResult.topicNameValues()insteadSince 3.3. UseAdmin.listConsumerGroupOffsets(java.util.Map, ListConsumerGroupOffsetsOptions)to specify topic partitions.org.apache.kafka.clients.admin.ListConsumerGroupOffsetsOptions.topicPartitions(List<TopicPartition>) Since 3.3. UseAdmin.listConsumerGroupOffsets(java.util.Map, ListConsumerGroupOffsetsOptions)to specify topic partitions.since 2.4 UseKafkaConsumer.committed(Set)insteadsince 2.4 UseKafkaConsumer.committed(Set, Duration)insteadSince 2.0. UseKafkaConsumer.poll(Duration), which does not block beyond the timeout awaiting partition assignment. See KIP-266 for more information.UseMockConsumer.setPollException(KafkaException)insteadSince 3.0.0, please useKafkaProducer.sendOffsetsToTransaction(Map, ConsumerGroupMetadata)instead.Since 3.3.0UseSinkTask.open(Collection)for partition initialization.UseSinkTask.close(Collection)instead for partition cleanup.Since 3.9. UseDeserializationExceptionHandler.handle(ErrorHandlerContext, ConsumerRecord, Exception)instead.Since 3.9. UseProductionExceptionHandler.handle(ErrorHandlerContext, ProducerRecord, Exception)instead.since 3.0.0 useKafkaStreams.metadataForAllStreamsClients()since 3.0.0 useKafkaStreams.streamsMetadataForStore(java.lang.String)insteadsince 3.0 useKafkaStreams.metadataForLocalThreads()Since 2.8.0. UseKafkaStreams.setUncaughtExceptionHandler(StreamsUncaughtExceptionHandler)instead.since 2.7.0; useKeyQueryMetadata.activeHost()instead.since 2.7.0; useKeyQueryMetadata.partition()instead.since 2.7.0; useKeyQueryMetadata.standbyHosts()instead.since 3.0. UseJoinWindows.ofTimeDifferenceAndGrace(Duration, Duration)insteadsince 3.0. UseJoinWindows.ofTimeDifferenceWithNoGrace(Duration)} insteadsince 2.8. UseKStream.split(Named)instead.since 2.8. UseKStream.split()instead.Since 3.3. UseKStream.process(ProcessorSupplier, String...)instead.Since 3.3. UseKStream.process(ProcessorSupplier, Named, String...)instead.Since 3.3. UseKStream.processValues(FixedKeyProcessorSupplier, String...)instead.Since 3.3. UseKStream.processValues(FixedKeyProcessorSupplier, Named, String...)instead.Since 3.3. UseKStream.processValues(FixedKeyProcessorSupplier, String...)instead.Since 3.3. UseKStream.processValues(FixedKeyProcessorSupplier, Named, String...)instead.org.apache.kafka.streams.kstream.KStream.process(ProcessorSupplier<? super K, ? super V>, String...) Since 3.0. UseKStream.process(org.apache.kafka.streams.processor.api.ProcessorSupplier, java.lang.String...)instead.since 2.6; useKStream.repartition()insteadsince 2.6; useKStream.repartition(Repartitioned)insteadSince 3.3. UseKStream.process(ProcessorSupplier, String...)instead.Since 3.3. UseKStream.process(ProcessorSupplier, Named, String...)instead.Since 3.3. UseKStream.processValues(FixedKeyProcessorSupplier, String...)instead.Since 3.3. UseKStream.processValues(FixedKeyProcessorSupplier, Named, String...)instead.Since 3.3. UseKStream.processValues(FixedKeyProcessorSupplier, String...)instead.Since 3.3. UseKStream.processValues(FixedKeyProcessorSupplier, Named, String...)instead.since 3.1, removal planned for 4.0. UseKTable.join(KTable, Function, ValueJoiner, TableJoined)instead.since 3.1, removal planned for 4.0. UseKTable.join(KTable, Function, ValueJoiner, TableJoined, Materialized)instead.since 3.1, removal planned for 4.0. UseKTable.leftJoin(KTable, Function, ValueJoiner, TableJoined)instead.since 3.1, removal planned for 4.0. UseKTable.leftJoin(KTable, Function, ValueJoiner, TableJoined, Materialized)instead.since 3.0. UseSessionWindows.ofInactivityGapAndGrace(Duration, Duration)insteadsince 3.0. UseSessionWindows.ofInactivityGapWithNoGrace(Duration)insteadsince 3.0. UseTimeWindows.ofSizeAndGrace(Duration, Duration)insteadsince 3.0. UseTimeWindows.ofSizeWithNoGrace(Duration)} insteadSince 3.0.0; useMockProcessorContext.setRecordTimestamp(long)instead.Since 2.7.0. Callers should invokeStateStore.init(StateStoreContext, StateStore)instead. Implementers may choose to implement this method for backward compatibility or to throw an informative exception instead.since 3.0, for internal use, will be removedsince 3.0, for internal use, will be removedsince 3.0, for internal use, will be removedsince 3.0, for internal use, will be removedSince 2.7.0; useStreamsBuilder.addGlobalStore(StoreBuilder, String, Consumed, ProcessorSupplier)instead.Since 2.7.0 UseTopology.addProcessor(String, ProcessorSupplier, String...)instead.
-
Deprecated ConstructorsConstructorDescriptionSince 3.0 use
TopicListing(String, Uuid, boolean)insteaduse one of the constructors without a `checksum` parameter. This constructor will be removed in Apache Kafka 4.0 (deprecated since 3.0).use one of the constructors without a `checksum` parameter. This constructor will be removed in Apache Kafka 4.0 (deprecated since 3.0).use one of the constructors without a `checksum` parameter. This constructor will be removed in Apache Kafka 4.0 (deprecated since 3.0).use constructor without `checksum` parameter. This constructor will be removed in Apache Kafka 4.0 (deprecated since 3.0).Since 2.6.0. UseJmxReporter()Initialize JmxReporter withJmxReporter.contextChange(MetricsContext)Populate prefix by adding _namespace/prefix key value pair toMetricsContext
Processorinstead.