reset

Use this command to reset a specific object's value back to its default on the cluster to which you are connected.

Synopsis

reset <ResetCommandArg> [ResetCommandArg Options]

Reset Command Forms

reset client <ClientName> consumer_byte_rate | producer_byte_rate | request_percentage
Reset values for a specified client application.
reset user <UserName> consumer_byte_rate | SCRAM-SHA-512 | SCRAM-SHA-256 | producer_byte_rate | request_percentage
Reset values for a specified user.
reset topic <TopicName> <Topic Option>
Reset values for a specified topic.
reset broker <BrokerID> <Broker Option>
Reset specified values for a specified Broker.

Broker Options

For details on the following options, refer to the Apache Kafka documentation.

  • advertised.listeners
  • background.threads
  • compression.type
  • follower.replication.throttled.rate
  • leader.replication.throttled.rate
  • listener.security.protocol.map
  • listeners
  • log.cleaner.backoff.ms
  • log.cleaner.dedupe.buffer.size
  • log.cleaner.delete.retention.ms
  • log.cleaner.io.buffer.load.factor
  • log.cleaner.io.buffer.size
  • log.cleaner.io.max.bytes.per.second
  • log.cleaner.min.cleanable.ratio
  • log.cleaner.min.compaction.lag.ms
  • log.cleaner.threads
  • log.cleanup.policy
  • log.flush.interval.messages
  • log.flush.interval.ms
  • log.index.interval.bytes
  • log.index.size.max.bytes
  • log.message.downconversion.enable
  • log.message.timestamp.difference.max.ms
  • log.message.timestamp.type
  • log.preallocate
  • log.retention.bytes
  • log.retention.ms
  • log.roll.jitter.ms
  • log.roll.ms
  • log.segment.bytes
  • log.segment.delete.delay.ms
  • max.connections.per.ip
  • max.connections.per.ip.overrides
  • message.max.bytes
  • metric.reporters
  • min.insync.replicas
  • num.io.threads
  • num.network.threads
  • num.recovery.threads.per.data.dir
  • num.replica.fetchers
  • principal.builder.class
  • replica.alter.log.dirs.io.max.bytes.per.second
  • sasl.enabled.mechanisms
  • sasl.jaas.config
  • sasl.kerberos.kinit.cmd
  • sasl.kerberos.min.time.before.relogin
  • sasl.kerberos.principal.to.local.rules
  • sasl.kerberos.service.name
  • sasl.kerberos.ticket.renew.jitter
  • sasl.kerberos.ticket.renew.window.factor
  • sasl.login.refresh.buffer.seconds
  • sasl.login.refresh.min.period.seconds
  • sasl.login.refresh.window.factor
  • sasl.login.refresh.window.jitter
  • sasl.mechanism.inter.broker.protocol
  • ssl.cipher.suites
  • ssl.client.auth
  • ssl.enabled.protocols
  • ssl.endpoint.identification.algorithm
  • ssl.key.password
  • ssl.keymanager.algorithm
  • ssl.keystore.location
  • ssl.keystore.password
  • ssl.keystore.type
  • ssl.protocol
  • ssl.provider
  • ssl.secure.random.implementation
  • ssl.trustmanager.algorithm
  • ssl.truststore.location
  • ssl.truststore.password
  • ssl.truststore.type
  • unclean.leader.election.enable

Topic Options

  • cleanup.policy
  • compression.type
  • delete.retention.ms
  • file.delete.delay.ms
  • flush.messages
  • flush.ms
  • follower.replication.throttled.replicas
  • index.interval.bytes
  • leader.replication.throttled.replicas
  • max.message.bytes
  • message.downconversion.enable
  • message.format.version
  • message.timestamp.difference.max.ms
  • message.timestamp.type
  • min.cleanable.dirty.ratio
  • min.compaction.lag.ms
  • min.insync.replicas
  • preallocate
  • retention.bytes
  • retention.ms
  • segment.bytes
  • segment.index.bytes
  • segment.jitter.ms
  • segment.ms
  • unclean.leader.election.enable

Examples

cluster@myCluster> reset topic topic2 cleanup.policy
	
cluster@myCluster> reset user User:* request_percentage

cluster@myCluster> reset client 0 consumer_byte_rate	

cluster@myCluster> reset broker 0 log.message.timestamp.type

See Also

set