The exactly once guarantee in the Kafka Streams is for which flow of data?
You want to send a message of size 3 MB to a topic with default message size configuration. How does KafkaProducer handle large messages?
A consumer wants to read messages from partitions 0 and 1 of a topic topic1. Code snippet is shown below.
consumer.subscribe(Arrays.asList("topic1"));
List<TopicPartition> pc = new ArrayList<>();
pc.add(new PartitionTopic("topic1", 0));
pc.add(new PartitionTopic("topic1", 1));
consumer.assign(pc);
Your Kafka cluster has five brokers. The topic t1 on the cluster has two partitions, and it has replication.factor
= 4, min.insync.replicas = 3.
You want to have strong durability guarantees for messages written to topic t1.
If you configure a producer 'acks=all', how many brokers need to acknowledge a message before it is considered committed?
If I want to have an extremely high confidence that leaders and replicas have my data, I should use