Kafka - with Java/Python
Consider this Kafka consumer code snippet:
What happens if the poll() method throws a TimeoutException and it is not caught?
try {
ConsumerRecords records = consumer.poll(Duration.ofMillis(500));
// process records
} catch (TimeoutException e) {
System.out.println("Polling timed out");
} What happens if the poll() method throws a TimeoutException and it is not caught?
