-
Classes Class Description org.apache.kafka.clients.producer.UniformStickyPartitioner Since 3.3.0, in order to use default partitioning logic remove thepartitioner.class
configuration 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.
org.apache.kafka.common.KafkaFuture.Function Since Kafka 3.0. Use theKafkaFuture.BaseFunction
functional interface.org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerLoginCallbackHandler See org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginCallbackHandlerorg.apache.kafka.common.security.oauthbearer.secured.OAuthBearerValidatorCallbackHandler See org.apache.kafka.common.security.oauthbearer.OAuthBearerValidatorCallbackHandler
-
Exceptions Exceptions Description org.apache.kafka.common.errors.NotLeaderForPartitionException since 2.6. UseNotLeaderOrFollowerException
.
-
Constructors Constructor Description org.apache.kafka.clients.admin.FeatureUpdate(short, boolean) org.apache.kafka.clients.admin.TopicListing(String, boolean) Since 3.0 useTopicListing(String, Uuid, boolean)
insteadorg.apache.kafka.clients.consumer.ConsumerRecord(String, int, long, long, TimestampType, long, int, int, K, V) use one of the constructors without a `checksum` parameter. This constructor will be removed in Apache Kafka 4.0 (deprecated since 3.0).org.apache.kafka.clients.producer.RecordMetadata(TopicPartition, long, long, long, Long, int, int) use constructor without `checksum` parameter. This constructor will be removed in Apache Kafka 4.0 (deprecated since 3.0).org.apache.kafka.common.metrics.JmxReporter(String) Since 2.6.0. UseJmxReporter()
Initialize JmxReporter withJmxReporter.contextChange(MetricsContext)
Populate prefix by adding _namespace/prefix key value pair toMetricsContext