-
Deprecated Interfaces
-
Deprecated ClassesClassDescriptionSince Kafka 3.0. Use the
KafkaFuture.BaseFunctionfunctional interface.Since 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.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.UseSinkTask.open(Collection)for partition initialization.UseSinkTask.close(Collection)instead for partition cleanup.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.UseKeyQueryMetadata.activeHost()instead.UseKeyQueryMetadata.partition()instead.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.