Skip to content

Commit

Permalink
ncm-metaconfig: kafka broker settings schema for 2.4
Browse files Browse the repository at this point in the history
  • Loading branch information
@itkovian
itkovian committed Apr 7, 2020
1 parent c4be987 commit a0921b7
Showing 1 changed file with 182 additions and 10 deletions.
192 changes: 182 additions & 10 deletions ncm-metaconfig/src/main/metaconfig/kafka/pan/schema.pan
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,26 +2,198 @@ declaration template metaconfig/kafka/schema;

include 'pan/types';


type kafka_server_properties = {
"zookeeper.connect" : string
"advertised.host.name" ? string
"advertised.listeners" ? string = "PLAINTEXT://localhost:9092"
"advertised.port" ? long(0..)
"auto.create.topics.enable" ? boolean
"auto.leader.rebalance.enable" ? boolean
"background.threads" ? long(1..)
"broker.id" : long(0..)
"group.initial.rebalance.delay.ms" ? long(0..)
"inter.broker.listener.name" ? string
"listener.security.protocol.map" ? string
"compression.type" ? string
"control.plane.listener.name" ? string
"delete.topic.enable" ? boolean
"host.name" ? string
"leader.imbalance.check.interval.seconds" ? long(0..)
"leader.imbalance.per.broker.percentage" ? long(0..)
"listeners" ? string = "PLAINTEXT://localhost:9092"
"log.dir" ? string
"log.dirs" : absolute_file_path
"log.flush.interval.messages" ? long(1..)
"log.flush.interval.ms" ? long(0..)
"log.flush.offset.checkpoint.interval.ms" ? long(0..)
"log.flush.scheduler.interval.ms" ? long(0..)
"log.flush.start.offset.checkpoint.interval.ms" ? long(0..)
"log.retention.bytes" ? long(0..)
"log.retention.hours" ? long(0..)
"log.retention.check.interval.ms" ? long(0..)
"log.retention.minutes" ? long(0..)
"log.retention.ms" ? long(0..)
"log.roll.hours" ? long(1..)
"log.roll.jitter.hours" ? long(0..)
"log.roll.jitter.ms" ? long(0..)
"log.roll.ms" ? long(0..)
"log.segment.bytes" ? long(0..)
"log.segment.delete.delay.ms" ? long(0..)
"message.max.bytes" ? long(0..)
"min.insync.replicas" ? long(1..)
"num.io.threads" ? long(1..)
"num.network.threads" ? long(1..)
"num.partitions" ? long(0..)
"num.recovery.threads.per.data.dir" ? long(1..)
"num.replica.alter.log.dirs.threads" ? long(0..)
"num.replica.fetchers" ? long(0..)
"offset.metadata.max.bytes" ? long(0..)
"offsets.commit.required.acks" ? long(0..)
"offsets.commit.timeout.ms" ? long(1..)
"offsets.load.buffer.size" ? long(1..)
"offsets.retention.check.interval.ms" ? long(1..)
"offsets.retention.minutes" ? long(1..)
"offsets.topic.compression.codec" ? long(0..)
"offsets.topic.num.partitions" ? long(1..)
"offsets.topic.replication.factor" ? long(1..)
"socket.send.buffer.bytes" ? long(0..)
"offsets.topic.segment.bytes" ? long(1..)
"port" ? long(0..)
"queued.max.requests" ? long(1..)
"quota.consumer.default" ? long(1..) # deprecated
"quota.producer.default" ? long(1..) # deprecated
"replica.fetch.min.bytes" ? long(1..)
"replica.fetch.wait.max.ms" ? long(0..)
"replica.high.watermark.checkpoint.interval.ms" ? long(0..)
"replica.lag.time.max.ms" ? long(0..)
"replica.socket.receive.buffer.bytes" ? long(0..)
"replica.socket.timeout.ms" ? long(0..)
"request.timeout.ms" ? long(0..)
"socket.receive.buffer.bytes" ? long(0..)
"socket.request.max.bytes" ? long(0..)
"zookeeper.connect" : string
"socket.request.max.bytes" ? long(1..)
"socket.send.buffer.bytes" ? long(0..)
"transaction.max.timeout.ms" ? long(1..)
"transaction.state.log.load.buffer.size" ? long(1..)
"transaction.state.log.min.isr" ? long(1..)
"transaction.state.log.num.partitions" ? long(1..)
"transaction.state.log.replication.factor" ? long(1..)
"transaction.state.log.segment.bytes" ? long(1..)
"transactional.id.expiration.ms" ? long(1..)
"unclean.leader.election.enable" ? boolean
"zookeeper.connection.timeout.ms" ? long(100..)
};
"zookeeper.max.in.flight.requests" ? long(1..)
"zookeeper.session.timeout.ms" ? long(0..)
"zookeeper.set.acl" ? boolean
"broker.id.generation.enable" ? boolean
"broker.rack" ? string
"connections.max.idle.ms" ? long(0..)
"connections.max.reauth.ms" ? long(0..)
"controlled.shutdown.enable" ? boolean
"controlled.shutdown.max.retries" ? long(0..)
"controlled.shutdown.retry.backoff.ms" ? long(0..)
"controller.socket.timeout.ms" ? long(0..)
"default.replication.factor" ? long(0..)
"delegation.token.expiry.time.ms" ? long(1..)
"delegation.token.master.key" ? string # password
"delegation.token.max.lifetime.ms" ? long(1..)
"delete.records.purgatory.purge.interval.requests" ? long(0..)
"fetch.purgatory.purge.interval.requests" ? long(0..)
"group.initial.rebalance.delay.ms" ? long(0..)
"group.max.session.timeout.ms" ? long(0..)
"group.max.size" ? long(1..)
"group.min.session.timeout.ms" ? long(0..)
"inter.broker.listener.name" ? string
"inter.broker.protocol.version" ? string
"log.cleaner.backoff.ms" ? long(0..)
"log.cleaner.dedupe.buffer.size" ? long(0..)
"log.cleaner.delete.retention.ms" ? long(0..)
"log.cleaner.enable" ? boolean
"log.cleaner.io.buffer.load.factor" ? double
"log.cleaner.io.buffer.size" ? long(0..)
"log.cleaner.io.max.bytes.per.second" ? double
"log.cleaner.max.compaction.lag.ms" ? long(0..)
"log.cleaner.min.cleanable.ratio" ? double
"log.cleaner.min.compaction.lag.ms" ? long(0..)
"log.cleaner.threads" ? long(0..)
"log.cleanup.policy" ? choice("compact", "delete")
"log.index.interval.bytes" ? long(0..)
"log.index.size.max.bytes" ? long(0..)
"log.message.format.version" ? string
"log.message.timestamp.difference.max.ms" ? long(0..)
"log.message.timestamp.type" ? string
"log.preallocate" ? boolean
"log.retention.check.interval.ms" ? long(1..)
"max.connections" ? long(0..)
"max.connections.per.ip" ? long(0..)
"max.connections.per.ip.overrides" ? string
"max.incremental.fetch.session.cache.slots" ? long(0..)
"num.partitions" ? long(1..)
"password.encoder.old.secret" ? string # password
"password.encoder.secret" ? string # password
"principal.builder.class" ? string
"producer.purgatory.purge.interval.requests" ? long(0..)
"queued.max.request.bytes" ? long(0..)
"replica.fetch.backoff.ms" ? long(0..)
"replica.fetch.max.bytes" ? long(0..)
"replica.fetch.response.max.bytes" ? long(0..)
"replica.selector.class" ? string
"reserved.broker.max.id" ? long(0..)
"sasl.client.callback.handler.class" ? string
"sasl.enabled.mechanisms" ? string[]
"sasl.jaas.config" ? string # password
"sasl.kerberos.kinit.cmd" ? string
"sasl.kerberos.min.time.before.relogin" ? long(0..)
"sasl.kerberos.principal.to.local.rules" ? string[]
"sasl.kerberos.service.name" ? string
"sasl.kerberos.ticket.renew.jitter" ? double
"sasl.kerberos.ticket.renew.window.factor" ? double
"sasl.login.callback.handler.class" ? string
"sasl.login.class" ? string
"sasl.login.refresh.buffer.seconds" ? long(0..)
"sasl.login.refresh.min.period.seconds" ? long(0..)
"sasl.login.refresh.window.factor" ? double
"sasl.login.refresh.window.jitter" ? double
"sasl.mechanism.inter.broker.protocol" ? string
"sasl.server.callback.handler.class" ? string
"security.inter.broker.protocol" ? string
"ssl.cipher.suites" ? string[]
"ssl.client.auth" ? string
"ssl.enabled.protocols" ? string[]
"ssl.key.password" ? string # password
"ssl.keymanager.algorithm" ? string
"ssl.keystore.location" ? string
"ssl.keystore.password" ? string # password
"ssl.keystore.type" ? string
"ssl.protocol" ? string
"ssl.provider" ? string
"ssl.trustmanager.algorithm" ? string
"ssl.truststore.location" ? string
"ssl.truststore.password" ? string # password
"ssl.truststore.type" ? string
"alter.config.policy.class.name" ? string
"alter.log.dirs.replication.quota.window.num" ? long(1..)
"alter.log.dirs.replication.quota.window.size.seconds" ? long(1..)
"authorizer.class.name" ? string
"client.quota.callback.class" ? string
"connection.failed.authentication.delay.ms" ? long(0..)
"create.topic.policy.class.name" ? string
"delegation.token.expiry.check.interval.ms" ? long(1..)
"kafka.metrics.polling.interval.secs" ? long(1..)
"kafka.metrics.reporters" ? string[]
"listener.security.protocol.map" ? string
"log.message.downconversion.enable" ? boolean
"metric.reporters" ? string[]
"metrics.num.samples" ? long(1..)
"metrics.recording.level" ? string
"metrics.sample.window.ms" ? long(1..)
"password.encoder.cipher.algorithm" ? string
"password.encoder.iterations" ? long(0..)
"password.encoder.key.length" ? long(0..)
"password.encoder.keyfactory.algorithm" ? string
"quota.window.num" ? long(1..)
"quota.window.size.seconds" ? long(1..)
"replication.quota.window.num" ? long(1..)
"replication.quota.window.size.seconds" ? long(1..)
"security.providers" ? string
"ssl.endpoint.identification.algorithm" ? string
"ssl.principal.mapping.rules" ? string
"ssl.secure.random.implementation" ? string
"transaction.abort.timed.out.transaction.cleanup.interval.ms" ? long(1..)
"transaction.remove.expired.transaction.cleanup.interval.ms" ? long(1..)
"zookeeper.sync.time.ms" ? long(0..)
};

0 comments on commit a0921b7

Please sign in to comment.