Page History

// Example 2: UnknownTopicOrPartitionException use case 
// In this example we except that if the record does NOT belong to the "important-topic", the producer follows the custom handler and fails.

public class Example2 {  
	public static void main(String[] args) {
        
		Properties producerProps = new Properties();
 	    producerProps.put("custom.exception.handler", Example2.MyProducerExceptionHandler.class.getName());
        // .....  omitted for brevity
        KafkaProducer<String, String> producer = new KafkaProducer(producerProps);

		producer.send(new ProducerRecord("output-topic"someMethodToComputeTopic(), "someMessage"));
		producer.flush();
		producer.close();
       
    }
	public static class MyProducerExceptionHandler implements ProducerExceptionHandler {
        @Override
        public ProducerExceptionHandler.Response handle(ProducerRecord<byte[], byte[]> producerRecord, Exception e) {
			if (e instanceOf UnknownTopicOrPartitionException) {
				if (producerRecord.topic().equals("important-topic") {
     				ProducerExceptionHandler.Response.RETRY;
				}
            	return ProducerExceptionHandler.Response.FAIL;
			}
			return null;
        }
        @Override
        public void configure(Map<String, ?> map) {

        }
    }
}