KafkaAdmin.getConfigurationProperties()
KafkaProducerException.getFailedProducerRecord()
ConsumerProperties.getTopicPartitions()
ProducerListener.onError(ProducerRecord, Exception)
ProducerListener.onSuccess(ProducerRecord, RecordMetadata)
GenericErrorHandler.isAckAfterHandle()