Archives of Support Questions (Read Only)

This is an archived board for historical reference. Information and links may no longer be available or relevant
Announcements
This board is archived and read-only for historical reference. To ask a new question, please post a new topic on the appropriate active board.

Kafka offset topic not following retention policy

avatar
Most topics (created by our app) are following the policy(deletes the data after 2 days). But, there is one which is internal to kafka which is used for consumer offset position(We use the client api to commit the offset). This is not being deleted after 2 days. kakfka broker version: 2.3.4.0-3485. Here are the retention policy values:

Converted the server.properties from kafka config to a txt and attaching it here:

Kafka broker retention policy configuration(from server.properties)server.txt:

############################# Log Retention Policy ############################# #

The following configurations control the disposal of log segments. The policy can # be set to delete segments after a period of time, or after a given size has accumulated. # A segment will be deleted whenever *either* of these criteria are met. Deletion always happens # from the end of the log. # The minimum age of a log file to be eligible for deletion log.retention.hours=48 # A size-based retention policy for logs. Segments are pruned from the log as long as the remaining # segments don't drop below log.retention.bytes. #log.retention.bytes=1073741824 # The maximum size of a log segment file. When this size is reached a new log segment will be created. log.segment.bytes=536870912 # The interval at which log segments are checked to see if they can be deleted according # to the retention policies log.retention.check.interval.ms=300000 # By default the log cleaner is disabled and the log retention policy will default to just delete segments after their retention expires. # If log.cleaner.enable=true is set the cleaner will be enabled and individual logs can then be marked for log compaction. log.cleaner.enable=false

1 ACCEPTED SOLUTION

avatar
Master Guru

There is actually a specific parameter for offset retention

offsets.retention.minutes which by default is 1440 or one day. So it actually should be deleted sooner.

http://kafka.apache.org/documentation.html

View solution in original post

1 REPLY 1

avatar
Master Guru

There is actually a specific parameter for offset retention

offsets.retention.minutes which by default is 1440 or one day. So it actually should be deleted sooner.

http://kafka.apache.org/documentation.html