You want to perform table lookups against a KTable everytime a new record is received from the KStream. What is the output of KStream-KTable join?
Which is an optional field in an Avro record?
A producer just sent a message to the leader broker for a topic partition. The producer used acks=1 and therefore the data has not yet been replicated to followers. Under which conditions will the consumer see the message?
Your Kafka cluster has five brokers. The topic t1 on the cluster has:
* Two partitions
* Replication factor = 4
* min.insync.replicas = 3You need strong durability guarantees for messages written to topic t1.You configure a producer acks=all and all the replicas for t1 are in-sync.How many brokers need to acknowledge a message before it is considered committed?
We have a store selling shoes. What dataset is a great candidate to be modeled as a KTable in Kafka Streams?
