while (true) {
ConsumerRecords<String, String> records = consumer.poll(100);
try {
consumer.commitSync();
} catch (CommitFailedException e) {
log.error("commit failed", e)
}
for (ConsumerRecord<String, String> record records)
{
System.out.printf("topic = %s, partition = %s, offset =
%d, customer = %s, country = %s
",
record.topic(), record.partition(),
record.offset(), record.key(), record.value());
}
}
What kind of delivery guarantee this consumer offers?

You are managing the schema of data in a Kafka Topic using Schema Registry. You need to add new fields to the message schema. You need to select a compatibility type that allows you to add required fields, delete optional fields, and allows consumers to read all previous versions of the schema.
Which compatibility type is correct?

Which configuration is used to determine which directory the connectors are stored in?

What data format isn't natively available with the Confluent REST Proxy?

To allow consumers in a group to resume at the previously committed offset, I need to set the proper value for...