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) |