now it also supports files ending in .sh

Author: AndreaTosti

kafka.zsh

@@ -41,6 +41,7 @@ _kafka_acls_args+=('--topic: topic to which ACLs should be added or removed. A v
 _kafka_acls_args+=('--transactional-id: The transactionalId to which ACLs should be added or removed. A value of * indicates the ACLs should apply to all transactionalIds.')
 _kafka_acls_args+=('--version: Display Kafka version.')
 compdef "_kafka-command kafka-acls" kafka-acls
+compdef "_kafka-command kafka-acls" kafka-acls.sh
 declare -a _kafka_avro_console_consumer_args
 _kafka_avro_console_consumer_args=()
 _kafka_avro_console_consumer_args+=('--bootstrap-server: REQUIRED: The server(s) to connect to.')
@@ -64,6 +65,7 @@ _kafka_avro_console_consumer_args+=('--value-deserializer:')
 _kafka_avro_console_consumer_args+=('--version: Display Kafka version.')
 _kafka_avro_console_consumer_args+=('--whitelist: Regular expression specifying whitelist of topics to include for consumption.')
 compdef "_kafka-command kafka-avro-console-consumer" kafka-avro-console-consumer
+compdef "_kafka-command kafka-avro-console-consumer" kafka-avro-console-consumer.sh
 declare -a _kafka_avro_console_producer_args
 _kafka_avro_console_producer_args=()
 _kafka_avro_console_producer_args+=('--batch-size: Number of messages to send in a single batch if they are not being sent synchronously. (default: 200)')
@@ -88,13 +90,15 @@ _kafka_avro_console_producer_args+=('--timeout: If set and the producer is runni
 _kafka_avro_console_producer_args+=('--topic: REQUIRED: The topic id to produce messages to.')
 _kafka_avro_console_producer_args+=('--version: Display Kafka version.')
 compdef "_kafka-command kafka-avro-console-producer" kafka-avro-console-producer
+compdef "_kafka-command kafka-avro-console-producer" kafka-avro-console-producer.sh
 declare -a _kafka_broker_api_versions_args
 _kafka_broker_api_versions_args=()
 _kafka_broker_api_versions_args+=('--bootstrap-server: REQUIRED: The server to connect to.')
 _kafka_broker_api_versions_args+=('--command-config: A property file containing configs to be passed to Admin Client.')
 _kafka_broker_api_versions_args+=('--help: Print usage information.')
 _kafka_broker_api_versions_args+=('--version: Display Kafka version.')
 compdef "_kafka-command kafka-broker-api-versions" kafka-broker-api-versions
+compdef "_kafka-command kafka-broker-api-versions" kafka-broker-api-versions.sh
 declare -a _kafka_configs_args
 _kafka_configs_args=()
 _kafka_configs_args+=('--add-config: Key Value pairs of configs to add. Square brackets can be used to group values which contain commas: ''k1=v1, k2=[v1,v2,v2],k3=v3''. The following is a list of valid configurations: For entity-type ''topics'': cleanup.policy compression.type confluent.append.record.interceptor. classes confluent.key.schema.validation confluent.placement.constraints confluent.tier.enable confluent.tier.local.hotset.bytes confluent.tier.local.hotset.ms confluent.value.schema.validation delete.retention.ms file.delete.delay.ms flush.messages flush.ms follower.replication.throttled. replicas index.interval.bytes leader.replication.throttled.replicas max.compaction.lag.ms 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 For entity-type ''brokers'': advertised.listeners background.threads compression.type confluent.append.record.interceptor. classes confluent.tier.enable confluent.tier.local.hotset.bytes confluent.tier.local.hotset.ms 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.max.compaction.lag.ms 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 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 For entity-type ''users'': SCRAM-SHA-256 SCRAM-SHA-512 consumer_byte_rate producer_byte_rate request_percentage For entity-type ''clients'': consumer_byte_rate producer_byte_rate request_percentage Entity types ''users'' and ''clients'' may be specified together to update config for clients of a specific user.')
@@ -112,6 +116,7 @@ _kafka_configs_args+=('--replica-placement: This configuration is a JSON object
 _kafka_configs_args+=('--version: Display Kafka version.')
 _kafka_configs_args+=('--zookeeper: REQUIRED: The connection string for the zookeeper connection in the form host:port. Multiple URLS can be given to allow fail-over.')
 compdef "_kafka-command kafka-configs" kafka-configs
+compdef "_kafka-command kafka-configs" kafka-configs.sh
 declare -a _kafka_console_consumer_args
 _kafka_console_consumer_args=()
 _kafka_console_consumer_args+=('--bootstrap-server: REQUIRED: The server(s) to connect to.')
@@ -135,6 +140,7 @@ _kafka_console_consumer_args+=('--value-deserializer:')
 _kafka_console_consumer_args+=('--version: Display Kafka version.')
 _kafka_console_consumer_args+=('--whitelist: Regular expression specifying whitelist of topics to include for consumption.')
 compdef "_kafka-command kafka-console-consumer" kafka-console-consumer
+compdef "_kafka-command kafka-console-consumer" kafka-console-consumer.sh
 declare -a _kafka_console_producer_args
 _kafka_console_producer_args=()
 _kafka_console_producer_args+=('--batch-size: Number of messages to send in a single batch if they are not being sent synchronously. (default: 200)')
@@ -159,6 +165,7 @@ _kafka_console_producer_args+=('--timeout: If set and the producer is running in
 _kafka_console_producer_args+=('--topic: REQUIRED: The topic id to produce messages to.')
 _kafka_console_producer_args+=('--version: Display Kafka version.')
 compdef "_kafka-command kafka-console-producer" kafka-console-producer
+compdef "_kafka-command kafka-console-producer" kafka-console-producer.sh
 declare -a _kafka_consumer_groups_args
 _kafka_consumer_groups_args=()
 _kafka_consumer_groups_args+=('--all-groups: Apply to all consumer groups.')
@@ -191,6 +198,7 @@ _kafka_consumer_groups_args+=('--topic: The topic whose consumer group informati
 _kafka_consumer_groups_args+=('--verbose: Provide additional information, if any, when describing the group. This option may be used with ''-- offsets''/''--members''/''--state'' and ''--bootstrap-server'' options only. Example: --bootstrap-server localhost: 9092 --describe --group group1 -- members --verbose')
 _kafka_consumer_groups_args+=('--version: Display Kafka version.')
 compdef "_kafka-command kafka-consumer-groups" kafka-consumer-groups
+compdef "_kafka-command kafka-consumer-groups" kafka-consumer-groups.sh
 declare -a _kafka_consumer_perf_test_args
 _kafka_consumer_perf_test_args=()
 _kafka_consumer_perf_test_args+=('--broker-list: REQUIRED: The server(s) to connect to.')
@@ -212,6 +220,7 @@ _kafka_consumer_perf_test_args+=('--timeout: The maximum allowed time in millise
 _kafka_consumer_perf_test_args+=('--topic: REQUIRED: The topic to consume from.')
 _kafka_consumer_perf_test_args+=('--version: Display Kafka version.')
 compdef "_kafka-command kafka-consumer-perf-test" kafka-consumer-perf-test
+compdef "_kafka-command kafka-consumer-perf-test" kafka-consumer-perf-test.sh
 declare -a _kafka_delegation_tokens_args
 _kafka_delegation_tokens_args=()
 _kafka_delegation_tokens_args+=('--bootstrap-server: REQUIRED: server(s) to use for bootstrapping.')
@@ -229,6 +238,7 @@ _kafka_delegation_tokens_args+=('--renew-time-period: Renew time period in milli
 _kafka_delegation_tokens_args+=('--renewer-principal: renewer is a kafka principal. It is should be in principalType:name format.')
 _kafka_delegation_tokens_args+=('--version: Display Kafka version.')
 compdef "_kafka-command kafka-delegation-tokens" kafka-delegation-tokens
+compdef "_kafka-command kafka-delegation-tokens" kafka-delegation-tokens.sh
 declare -a _kafka_topics_args
 _kafka_topics_args=()
 _kafka_topics_args+=('--alter: Alter the number of partitions, replica assignment, and/or configuration for the topic.')
@@ -259,9 +269,11 @@ _kafka_topics_args+=('--under-replicated-partitions: if set when describing topi
 _kafka_topics_args+=('--version: Display Kafka version.')
 _kafka_topics_args+=('--zookeeper: DEPRECATED, The connection string for the zookeeper connection in the form host:port. Multiple hosts can be given to allow fail-over.')
 compdef "_kafka-command kafka-topics" kafka-topics
+compdef "_kafka-command kafka-topics" kafka-topics.sh
 declare -a _kafka_producer_perf_test_args
 _kafka_producer_perf_test_args=()
 compdef "_kafka-command kafka-producer-perf-test" kafka-producer-perf-test
+compdef "_kafka-command kafka-producer-perf-test" kafka-producer-perf-test.sh
 declare -a _kafka_dump_log_args
 _kafka_dump_log_args=()
 _kafka_dump_log_args+=('--deep-iteration: if set, uses deep instead of shallow iteration. Automatically set if print- data-log is enabled.')
@@ -277,6 +289,7 @@ _kafka_dump_log_args+=('--value-decoder-class: if set, used to deserialize the m
 _kafka_dump_log_args+=('--verify-index-only: if set, just verify the index log without printing its content.')
 _kafka_dump_log_args+=('--version: Display Kafka version.')
 compdef "_kafka-command kafka-dump-log" kafka-dump-log
+compdef "_kafka-command kafka-dump-log" kafka-dump-log.sh
 declare -a _kafka_log_dirs_args
 _kafka_log_dirs_args=()
 _kafka_log_dirs_args+=('--bootstrap-server: REQUIRED: the server(s) to use for bootstrapping')
@@ -287,12 +300,15 @@ _kafka_log_dirs_args+=('--help: Print usage information.')
 _kafka_log_dirs_args+=('--topic-list: The list of topics to be queried in the form "topic1,topic2,topic3". All topics will be queried if no topic list is specified (default: )')
 _kafka_log_dirs_args+=('--version: Display Kafka version.')
 compdef "_kafka-command kafka-log-dirs" kafka-log-dirs
+compdef "_kafka-command kafka-log-dirs" kafka-log-dirs.sh
 declare -a _kafka_verifiable_consumer_args
 _kafka_verifiable_consumer_args=()
 compdef "_kafka-command kafka-verifiable-consumer" kafka-verifiable-consumer
+compdef "_kafka-command kafka-verifiable-consumer" kafka-verifiable-consumer.sh
 declare -a _kafka_verifiable_producer_args
 _kafka_verifiable_producer_args=()
 compdef "_kafka-command kafka-verifiable-producer" kafka-verifiable-producer
+compdef "_kafka-command kafka-verifiable-producer" kafka-verifiable-producer.sh
 declare -a _kafka_streams_application_reset_args
 _kafka_streams_application_reset_args=()
 _kafka_streams_application_reset_args+=('--bootstrap-servers: Comma-separated list of broker urls with format: HOST1:PORT1,HOST2:PORT2 (default: localhost:9092)')
@@ -312,6 +328,7 @@ _kafka_streams_application_reset_args+=('--to-offset: Reset offsets to a specifi
 _kafka_streams_application_reset_args+=('--version: Print version information and exit.')
 _kafka_streams_application_reset_args+=('--zookeeper: Zookeeper option is deprecated by bootstrap.servers, as the reset tool would no longer access Zookeeper directly.')
 compdef "_kafka-command kafka-streams-application-reset" kafka-streams-application-reset
+compdef "_kafka-command kafka-streams-application-reset" kafka-streams-application-reset.sh
 declare -a _kafka_mirror_maker_args
 _kafka_mirror_maker_args=()
 _kafka_mirror_maker_args+=('--abort.on.send.failure: Configure the mirror maker to exit on a failed send. (default: true)')
@@ -328,6 +345,7 @@ _kafka_mirror_maker_args+=('--rebalance.listener.args: Arguments used by custom
 _kafka_mirror_maker_args+=('--version: Display Kafka version.')
 _kafka_mirror_maker_args+=('--whitelist: Whitelist of topics to mirror.')
 compdef "_kafka-command kafka-mirror-maker" kafka-mirror-maker
+compdef "_kafka-command kafka-mirror-maker" kafka-mirror-maker.sh
 declare -a _kafka_delete_records_args
 _kafka_delete_records_args=()
 _kafka_delete_records_args+=('--bootstrap-server: REQUIRED: The server to connect to.')
@@ -336,9 +354,11 @@ _kafka_delete_records_args+=('--help: Print usage information.')
 _kafka_delete_records_args+=('--offset-json-file: REQUIRED: The JSON file with offset per partition. The format to use is: {"partitions": [{"topic": "foo", "partition": 1, "offset": 1}], "version":1 }')
 _kafka_delete_records_args+=('--version: Display Kafka version.')
 compdef "_kafka-command kafka-delete-records" kafka-delete-records
+compdef "_kafka-command kafka-delete-records" kafka-delete-records.sh
 declare -a _replicator_args
 _replicator_args=()
 compdef "_kafka-command replicator" replicator
+compdef "_kafka-command replicator" replicator.sh
 declare -a _kafka_reassign_partitions_args
 _kafka_reassign_partitions_args=()
 _kafka_reassign_partitions_args+=('--bootstrap-server: the server(s) to use for bootstrapping. REQUIRED if an absolute path of the log directory is specified for any replica in the reassignment json file')
@@ -357,3 +377,4 @@ _kafka_reassign_partitions_args+=('--verify: Verify if the reassignment complete
 _kafka_reassign_partitions_args+=('--version: Display Kafka version.')
 _kafka_reassign_partitions_args+=('--zookeeper: REQUIRED: The connection string for the zookeeper connection in the form host:port. Multiple URLS can be given to allow fail-over.')
 compdef "_kafka-command kafka-reassign-partitions" kafka-reassign-partitions
+compdef "_kafka-command kafka-reassign-partitions" kafka-reassign-partitions.sh