| Interface | Description |
|---|---|
| org.apache.kafka.common.security.auth.PrincipalBuilder |
As of Kafka 1.0.0, use
KafkaPrincipalBuilder instead. This will be removed in
a future major release. |
| org.apache.kafka.streams.processor.StateStoreSupplier |
use
StoreSupplier |
| Class | Description |
|---|---|
| org.apache.kafka.common.security.auth.DefaultPrincipalBuilder |
As of Kafka 1.0.0. This will be removed in a future major release.
|
| Field | Description |
|---|---|
| org.apache.kafka.common.config.SslConfigs.DEFAULT_PRINCIPAL_BUILDER_CLASS |
As of 1.0.0. This field will be removed in a future major release. In recent versions,
the config is optional and there is no default.
|
| org.apache.kafka.common.config.SaslConfigs.DEFAULT_SASL_ENABLED_MECHANISMS |
As of 1.0.0. This field will be removed in a future major release.
|
| org.apache.kafka.common.config.SaslConfigs.DEFAULT_SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES |
As of 1.0.0. This field will be removed in a future major release.
|
| org.apache.kafka.common.config.SslConfigs.PRINCIPAL_BUILDER_CLASS_CONFIG |
As of 1.0.0. This field will be removed in a future major release.
|
| org.apache.kafka.common.config.SslConfigs.PRINCIPAL_BUILDER_CLASS_DOC |
As of 1.0.0. This field will be removed in a future major release.
|
| org.apache.kafka.common.config.SaslConfigs.SASL_ENABLED_MECHANISMS |
As of 1.0.0. This field will be removed in a future major release.
|
| org.apache.kafka.common.config.SaslConfigs.SASL_ENABLED_MECHANISMS_DOC |
As of 1.0.0. This field will be removed in a future major release.
|
| org.apache.kafka.common.config.SaslConfigs.SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES |
As of 1.0.0. This field will be removed in a future major release.
|
| org.apache.kafka.common.config.SaslConfigs.SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES_DOC |
As of 1.0.0. This field will be removed in a future major release.
|
| org.apache.kafka.common.config.SslConfigs.SSL_CLIENT_AUTH_CONFIG |
As of 1.0.0. This field will be removed in a future major release.
|
| org.apache.kafka.common.config.SslConfigs.SSL_CLIENT_AUTH_DOC |
As of 1.0.0. This field will be removed in a future major release.
|
| Method | Description |
|---|---|
| org.apache.kafka.streams.StreamsBuilder.addGlobalStore(StoreBuilder, String, String, Consumed, String, ProcessorSupplier) | |
| org.apache.kafka.clients.consumer.ConsumerRecord.checksum() |
As of Kafka 0.11.0. Because of the potential for message format conversion on the broker, the
checksum returned by the broker may not match what was computed by the producer.
It is therefore unsafe to depend on this checksum for end-to-end delivery guarantees. Additionally,
message format v2 does not include a record-level checksum (for performance, the record checksum
was replaced with a batch checksum). To maintain compatibility, a partial checksum computed from
the record timestamp, serialized key size, and serialized value size is returned instead, but
this should not be depended on for end-to-end reliability.
|
| org.apache.kafka.clients.producer.RecordMetadata.checksum() |
As of Kafka 0.11.0. Because of the potential for message format conversion on the broker, the
computed checksum may not match what was stored on the broker, or what will be returned to the consumer.
It is therefore unsafe to depend on this checksum for end-to-end delivery guarantees. Additionally,
message format v2 does not include a record-level checksum (for performance, the record checksum
was replaced with a batch checksum). To maintain compatibility, a partial checksum computed from
the record timestamp, serialized key size, and serialized value size is returned instead, but
this should not be depended on for end-to-end reliability.
|
| org.apache.kafka.clients.consumer.Consumer.close(long, TimeUnit) | |
| org.apache.kafka.clients.consumer.KafkaConsumer.close(long, TimeUnit) |
Since 2.0. Use
KafkaConsumer.close(Duration) or KafkaConsumer.close(). |
| org.apache.kafka.streams.processor.ProcessorContext.forward(K, V, int) |
please use
ProcessorContext.forward(Object, Object, To) instead |
| org.apache.kafka.streams.processor.ProcessorContext.forward(K, V, String) |
please use
ProcessorContext.forward(Object, Object, To) instead |
| org.apache.kafka.common.security.auth.KafkaPrincipal.fromString(String) |
As of 1.0.0. This method will be removed in a future major release.
|
| org.apache.kafka.streams.StreamsConfig.getConsumerConfigs(String, String) | |
| org.apache.kafka.connect.sink.SinkTask.onPartitionsAssigned(Collection<TopicPartition>) |
Use
SinkTask.open(Collection) for partition initialization. |
| org.apache.kafka.connect.sink.SinkTask.onPartitionsRevoked(Collection<TopicPartition>) |
Use
SinkTask.close(Collection) instead for partition cleanup. |
| org.apache.kafka.clients.consumer.NoOffsetForPartitionException.partition() |
please use
NoOffsetForPartitionException.partitions |
| org.apache.kafka.clients.consumer.Consumer.poll(long) | |
| org.apache.kafka.clients.consumer.KafkaConsumer.poll(long) |
Since 2.0. Use
KafkaConsumer.poll(Duration), which does not block beyond the timeout awaiting partition
assignment. See KIP-266 for more information. |
| org.apache.kafka.clients.consumer.MockConsumer.poll(long) | |
| org.apache.kafka.common.Metric.value() |
As of 1.0.0, use
Metric.metricValue() instead. This will be removed in a future major release. |
| Constructor | Description |
|---|---|
| org.apache.kafka.common.acl.AclBinding(Resource, AccessControlEntry) |
Since 2.0. Use
AclBinding(ResourcePattern, AccessControlEntry) |
| org.apache.kafka.common.acl.AclBindingFilter(ResourceFilter, AccessControlEntryFilter) | |
| org.apache.kafka.clients.admin.ConfigEntry(String, String, boolean, boolean, boolean) |
since 1.1.0. This constructor will be removed in a future release.
|
| org.apache.kafka.streams.KafkaStreams(Topology, StreamsConfig) |
use
KafkaStreams(Topology, Properties) instead |
| org.apache.kafka.streams.KafkaStreams(Topology, StreamsConfig, Time) |
use
KafkaStreams(Topology, Properties, Time) instead |
| org.apache.kafka.streams.KafkaStreams(Topology, StreamsConfig, KafkaClientSupplier) |