| Field and Description |
|---|
| org.apache.kafka.clients.producer.ProducerConfig.BLOCK_ON_BUFFER_FULL_CONFIG
This config will be removed in a future release. Please use
ProducerConfig.MAX_BLOCK_MS_CONFIG. |
| org.apache.kafka.clients.producer.ProducerConfig.METADATA_FETCH_TIMEOUT_CONFIG
This config will be removed in a future release. Please use
ProducerConfig.MAX_BLOCK_MS_CONFIG |
| org.apache.kafka.clients.producer.ProducerConfig.TIMEOUT_CONFIG
This config will be removed in a future release. Please use
ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG |
| org.apache.kafka.streams.StreamsConfig.ZOOKEEPER_CONNECT_CONFIG
Kakfa Streams does not use Zookeeper anymore and this parameter will be ignored.
|
| Method and Description |
|---|
| org.apache.kafka.connect.sink.SinkTask.onPartitionsAssigned(Collection Use
SinkTask.open(Collection) for partition initialization. |
| org.apache.kafka.connect.sink.SinkTask.onPartitionsRevoked(Collection Use
SinkTask.close(Collection) instead for partition cleanup. |
| Constructor and Description |
|---|
| org.apache.kafka.common.Cluster(Collection Use the Cluster constructor with 5 parameters
|
| org.apache.kafka.common.MetricName(String, String)
This method will be removed in a future release.
Please create MetricName by method
Metrics.metricName(String, String) |
| org.apache.kafka.common.MetricName(String, String, Map This method will be removed in a future release.
Please create MetricName by method
Metrics.metricName(String, String, Map) |
| org.apache.kafka.common.MetricName(String, String, String)
This method will be removed in a future release.
Please create MetricName by method
Metrics.metricName(String, String, String) |
| org.apache.kafka.common.MetricName(String, String, String, String...)
This method will be removed in a future release.
Please create MetricName by method
Metrics.metricName(String, String, String, String...) |
| org.apache.kafka.clients.producer.RecordMetadata(TopicPartition, long, long) |