consumer-loop.java

// simplified consumer
try {
    while (true) {
	// fetch latest flag values and apply accordingly
	applyFeatureFlags(consumer);

        ConsumerRecords<String, String> records = consumer.poll(100);
        for (ConsumerRecord<String, String> record : records) {
            // logic
        }
    }
} finally {
    consumer.close();
}