Package org.voltdb.stream.api.kafka

Interface KafkaSourceExceptionHandler

public interface KafkaSourceExceptionHandler

This handler handles only errors of the poll step, this can be any of consumer misconfiguration, timeout exception, deserialization exception. For more information see KafkaConsumer.poll(Duration).

Method Summary

Modifier and Type	Method	Description
void	handle(org.apache.kafka.clients.consumer.KafkaConsumer<Object,Object> kafkaConsumer, ExecutionContext context, Exception ex)

Method Details

handle

void handle(org.apache.kafka.clients.consumer.KafkaConsumer<Object,Object> kafkaConsumer,
 ExecutionContext context,
 Exception ex)