DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
| Table of Contents |
|---|
Status
Current state: Under Discussion
...
However, there is no standardized or consistent approach for determining which source takes precedence when multiple are provided simultaneously. This inconsistency can cause user confusion and make the system more error-prone.
This KIP aims to establish a clear and uniform precedence order precedence order for property loading.
Furthermore, the validation of required arguments, such as --bootstrap-server and --bootstrap-controller, should consider multiple sources. For existing tool scripts, these arguments are only validated when provided via the command line "--bootstrap-server" or "--bootstrap-controller". However, they could also be specified through properties passed as key=value pairs via the command line or configuration files.
...
All of the tools listed below should use the helper methods to ensure they honor the proposed precedence.
| Tools | *New "modern" Option for Deprecation | Validating Required Arguments from Multiple Sources | Previous Jira/Email Discussion | Note | ||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|
| kafka-acls.sh | --bootstrap-server --bootstrap-controller | |||||||||||
kafka-broker-api-versions.sh | --bootstrap-server | |||||||||||
| kafka-client-metrics.sh | --bootstrap-server | |||||||||||
| kafka-cluster.sh | --bootstrap-server --bootstrap-controller | |||||||||||
| kafka-configs.sh | --bootstrap-server --bootstrap-controller | |||||||||||
| kafka-console-consumer.sh | For formatter: KEY_DESERIALIZER_CLASS_CONFIG VALUE_DESERIALIZER_CLASS_CONFIG | --bootstrap-server --from-beginning (AUTO_OFFSET_RESET_CONFIG) --group (GROUP_ID_CONFIG) is validated, but not following the proposed flow | ||||||||||
| kafka-console-producer.sh | KEY_SERIALIZER_CLASS_CONFIG VALUE_SERIALIZER_CLASS_CONFIG COMPRESSION_TYPE_CONFIG | --bootstrap-server |
| |||||||||
| kafka-console-share-consumer.sh | For formatter: KEY_DESERIALIZER_CLASS_CONFIG VALUE_DESERIALIZER_CLASS_CONFIG | --bootstrap-server --group (GROUP_ID_CONFIG) is validated, but not following the proposed flow | ||||||||||
| kafka-consumer-groups.sh | --bootstrap-server | |||||||||||
| kafka-consumer-perf-test.sh | GROUP_ID_CONFIG RECEIVE_BUFFER_CONFIG MAX_PARTITION_FETCH_BYTES_CONFIG AUTO_OFFSET_RESET_CONFIG KEY_DESERIALIZER_CLASS_CONFIG VALUE_DESERIALIZER_CLASS_CONFIG CHECK_CRCS_CONFIG | --bootstrap-server |
| |||||||||
| kafka-delegation-tokens.sh | --bootstrap-server | |||||||||||
| kafka-delete-records.sh | --bootstrap-server | |||||||||||
kafka-e2e-latency.sh | For consumer: GROUP_ID_CONFIG ENABLE_AUTO_COMMIT_CONFIG AUTO_OFFSET_RESET_CONFIG KEY_DESERIALIZER_CLASS_CONFIG VALUE_DESERIALIZER_CLASS_CONFIG FETCH_MAX_WAIT_MS_CONFIG For producer: LINGER_MS_CONFIG MAX_BLOCK_MS_CONFIG ACKS_CONFIG KEY_SERIALIZER_CLASS_CONFIG VALUE_SERIALIZER_CLASS_CONFIG | --bootstrap-server --producer-acks (ACKS_CONFIG) | ||||||||||
| kafka-features.sh | --bootstrap-server --bootstrap-controller | |||||||||||
kafka-get-offsets.sh | CLIENT_ID_CONFIG | --bootstrap-server | ||||||||||
kafka-groups.sh | --bootstrap-server | |||||||||||
kafka-leader-election.sh | --bootstrap-server | |||||||||||
kafka-log-dirs.sh | --bootstrap-server | |||||||||||
kafka-metadata-quorum.sh | --bootstrap-server --bootstrap-controller | |||||||||||
kafka-producer-perf-test.sh | KEY_SERIALIZER_CLASS_CONFIG VALUE_SERIALIZER_CLASS_CONFIG | |||||||||||
kafka-reassign-partitions.sh | --bootstrap-server --bootstrap-controller | |||||||||||
kafka-share-consumer-perf-test.sh | GROUP_ID_CONFIG RECEIVE_BUFFER_CONFIG MAX_PARTITION_FETCH_BYTES_CONFIG AUTO_OFFSET_RESET_CONFIG KEY_DESERIALIZER_CLASS_CONFIG VALUE_DESERIALIZER_CLASS_CONFIG CHECK_CRCS_CONFIG | --bootstrap-server | ||||||||||
kafka-share-groups.sh | --bootstrap-server | |||||||||||
kafka-streams-application-reset.sh | --bootstrap-server | This tool script is the only one with a default bootstrap-server; consider aligning it with the others. | ||||||||||
kafka-streams-groups.sh | --bootstrap-server | |||||||||||
kafka-topics.sh | --bootstrap-server | |||||||||||
kafka-transactions.sh | --bootstrap-server | |||||||||||
kafka-verifiable-consumer.sh | GROUP_PROTOCOL_CONFIG GROUP_REMOTE_ASSIGNOR_CONFIG PARTITION_ASSIGNMENT_STRATEGY_CONFIG --group-id (GROUP_ID_CONFIG) ENABLE_AUTO_COMMIT_CONFIG AUTO_OFFSET_RESET_CONFIG | --bootstrap-server --group-id (GROUP_ID_CONFIG) | ||||||||||
kafka-verifiable-producer.sh | KEY_SERIALIZER_CLASS_CONFIG VALUE_SERIALIZER_CLASS_CONFIG ACKS_CONFIG RETRIES_CONFIG | --bootstrap-server | ||||||||||
kafka-verifiable-share-consumer.sh | --bootstrap-server --group-id (GROUP_ID_CONFIG) |
*New "modern" Option for Deprecation - Indicates that the tool script currently has properties that do not follow the proposed precedence.
...