The producer code below features a Callback class with a method called onCompletion().
In the onCompletion() method, when the request is completed successfully, what does the value metadata.offset() represent?
A consumer starts and has auto.offset.reset=none, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed the offset 10 for the topic before. Where will the consumer read from?
Which actions will trigger partition rebalance for a consumer group? (select three)
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?
How will you read all the messages from a topic in your KSQL query?
