How will you change the retention time in Kafka at runtime?

1.	How will you change the retention time in Kafka at runtime?
Answer» A topic's retention time can be configured in Kafka. A topic's DEFAULT retention time is seven days. While creating a new subject, we can set the retention time. When a topic is GENERATED, the broker's property log.retention.hours are used to set the retention time. When configurations for a currently operating topic need to be modified, kafka-topic.sh must be used. The right COMMAND is determined on the Kafka version in USE. The command to use up to 0.8.2 is kafka-topics.sh --alter. Use kafka-configs.sh --alter STARTING with version 0.9.0.

Answer»

A topic's retention time can be configured in Kafka. A topic's DEFAULT retention time is seven days. While creating a new subject, we can set the retention time. When a topic is GENERATED, the broker's property log.retention.hours are used to set the retention time. When configurations for a currently operating topic need to be modified, kafka-topic.sh must be used.

The right COMMAND is determined on the Kafka version in USE.

The command to use up to 0.8.2 is kafka-topics.sh --alter.
Use kafka-configs.sh --alter STARTING with version 0.9.0.

Discussion

No Comment Found

Related InterviewSolutions

What are Znodes in Kafka Zookeeper? How many types of Znodes are there?
Differentiate between Kafka streams and Spark Streaming.
How will you change the retention time in Kafka at runtime?
What do you mean by BufferExhaustedException and OutOfMemoryException in Kafka?
Can the number of partitions for a topic be changed in Kafka?
What do you mean by graceful shutdown in Kafka?
How will you expand a cluster in Kafka?
What do you mean by an unbalanced cluster in Kafka? How can you balance it?
What are the guarantees that Kafka provides?
What do you understand about log compaction and quotas in Kafka?

How will you change the retention time in Kafka at runtime?

Discussion

No Comment Found

Related InterviewSolutions

Reply to Comment