When is the onCompletion() method called?
private class ProducerCallback implements Callback {
@Override
public void onCompletion(RecordMetadata recordMetadata, Exception e) { if (e != null) {
Correct Answer:C
Callback is invoked when a broker response is received.
You want to send a message of size 3 MB to a topic with default message size configuration. How does KafkaProducer handle large messages?
Correct Answer:C
MessageSizeTooLarge is not a retryable exception.
An ecommerce wesbite sells some custom made goods. What's the natural way of modeling this data in Kafka streams?
Correct Answer:B
Mostly-static data is modeled as a table whereas business transactions should be modeled as a stream.
To read data from a topic, the following configuration is needed for the consumers
Correct Answer:B
All brokers can respond to Metadata request, so a client can connect to any broker in the cluster.
What is the default port that the KSQL server listens on?
Correct Answer:B
Default port of KSQL server is 8088