This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 548fb18099b MINOR: Fix typo for the headers.separator cli option
(#20489)
add 0a12eaa80e9 KAFKA-19112 Unifying LIST-Type Configuration Validation
and Default Values (#20334)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/admin/AdminClientConfig.java | 10 ++-
.../kafka/clients/consumer/ConsumerConfig.java | 26 +++---
.../consumer/ConsumerPartitionAssignor.java | 3 -
.../kafka/clients/producer/ProducerConfig.java | 22 +++--
.../org/apache/kafka/common/config/ConfigDef.java | 58 +++++++++++--
.../apache/kafka/common/config/SaslConfigs.java | 4 +-
.../org/apache/kafka/common/config/SslConfigs.java | 9 +-
.../apache/kafka/common/config/TopicConfig.java | 5 +-
.../config/internals/BrokerSecurityConfigs.java | 4 +-
.../security/oauthbearer/BrokerJwtValidator.java | 5 +-
.../security/ssl/DefaultSslEngineFactory.java | 4 +-
.../kafka/clients/GroupRebalanceConfigTest.java | 11 ++-
.../internals/AdminBootstrapAddressesTest.java | 18 ++--
.../kafka/clients/consumer/ConsumerConfigTest.java | 13 ++-
.../consumer/ConsumerPartitionAssignorTest.java | 1 +
.../kafka/clients/consumer/KafkaConsumerTest.java | 43 ++++++++--
.../consumer/KafkaShareConsumerMetricsTest.java | 1 +
.../clients/consumer/KafkaShareConsumerTest.java | 3 +-
.../internals/CommitRequestManagerTest.java | 15 ++--
.../internals/FetchRequestManagerTest.java | 1 +
.../internals/NetworkClientDelegateTest.java | 2 +
.../internals/ShareConsumeRequestManagerTest.java | 5 +-
.../StreamsGroupHeartbeatRequestManagerTest.java | 3 +-
.../internals/TopicMetadataRequestManagerTest.java | 1 +
.../kafka/clients/producer/KafkaProducerTest.java | 97 +++++++++++++++-------
.../kafka/clients/producer/ProducerConfigTest.java | 14 +++-
.../apache/kafka/common/config/ConfigDefTest.java | 55 ++++++++++++
.../common/network/SslTransportLayerTest.java | 5 +-
.../security/ssl/DefaultSslEngineFactoryTest.java | 12 +--
.../apache/kafka/test/MockConsumerInterceptor.java | 1 +
.../apache/kafka/test/MockProducerInterceptor.java | 1 +
.../java/org/apache/kafka/test/TestSslUtils.java | 7 +-
.../kafka/connect/mirror/MirrorClientConfig.java | 15 ++--
.../kafka/connect/mirror/DefaultGroupFilter.java | 2 +
.../connect/mirror/MirrorCheckpointConfig.java | 2 +
.../connect/mirror/MirrorCheckpointTaskConfig.java | 10 +--
.../connect/mirror/MirrorConnectorConfig.java | 2 +
.../kafka/connect/mirror/MirrorMakerConfig.java | 4 +-
.../kafka/connect/mirror/MirrorSourceConfig.java | 3 +
.../connect/mirror/MirrorSourceTaskConfig.java | 6 +-
.../connect/mirror/MirrorMakerConfigTest.java | 14 +++-
.../kafka/connect/runtime/SinkConnectorConfig.java | 4 +-
.../apache/kafka/connect/runtime/WorkerConfig.java | 21 +++--
.../connect/runtime/rest/RestServerConfig.java | 46 ++--------
.../kafka/connect/runtime/rest/util/SSLUtils.java | 7 +-
.../runtime/AbstractWorkerSourceTaskTest.java | 1 +
.../kafka/connect/runtime/ConnectMetricsTest.java | 8 +-
.../connect/runtime/ErrorHandlingTaskTest.java | 1 +
.../runtime/ExactlyOnceWorkerSourceTaskTest.java | 3 +-
.../kafka/connect/runtime/MockConnectMetrics.java | 1 +
.../runtime/SourceTaskOffsetCommitterTest.java | 1 +
.../kafka/connect/runtime/WorkerSinkTaskTest.java | 1 +
.../runtime/WorkerSinkTaskThreadedTest.java | 5 +-
.../connect/runtime/WorkerSourceTaskTest.java | 1 +
.../apache/kafka/connect/runtime/WorkerTest.java | 3 +-
.../runtime/distributed/WorkerGroupMemberTest.java | 2 +
.../errors/RetryWithToleranceOperatorTest.java | 1 +
.../runtime/isolation/MultiVersionTest.java | 1 +
.../connect/runtime/isolation/PluginsTest.java | 1 +
.../connect/runtime/rest/RestServerConfigTest.java | 2 +-
.../runtime/standalone/StandaloneConfigTest.java | 1 +
.../storage/FileOffsetBackingStoreTest.java | 2 +
.../kafka/connect/transforms/DropHeaders.java | 4 +-
.../apache/kafka/connect/transforms/MaskField.java | 4 +-
.../kafka/connect/transforms/ReplaceField.java | 12 ++-
.../kafka/connect/transforms/ValueToKey.java | 3 +-
.../scala/kafka/metrics/KafkaMetricsConfig.scala | 4 +-
core/src/main/scala/kafka/server/KafkaConfig.scala | 21 ++---
core/src/main/scala/kafka/utils/CoreUtils.scala | 6 +-
.../kafka/server/KRaftClusterTest.scala | 2 +-
.../kafka/server/QuorumTestHarness.scala | 6 +-
.../test/scala/unit/kafka/KafkaConfigTest.scala | 39 +++++++--
.../test/scala/unit/kafka/log/LogConfigTest.scala | 4 +-
.../test/scala/unit/kafka/log/UnifiedLogTest.scala | 54 ++++++++++++
.../scala/unit/kafka/server/KafkaConfigTest.scala | 23 ++---
docs/configuration.html | 1 +
docs/upgrade.html | 29 +++++++
.../coordinator/group/GroupCoordinatorConfig.java | 6 +-
.../apache/kafka/server/config/ServerConfigs.java | 5 +-
.../kafka/server/config/ServerLogConfigs.java | 4 +-
.../apache/kafka/network/SocketServerConfigs.java | 14 ++--
.../kafka/server/config/AbstractKafkaConfig.java | 6 +-
.../apache/kafka/server/config/KRaftConfigs.java | 4 +-
.../kafka/server/metrics/ClientMetricsConfigs.java | 14 +++-
.../apache/kafka/server/metrics/MetricConfigs.java | 8 +-
.../kafka/network/SocketServerConfigsTest.java | 22 ++---
.../transaction/AddPartitionsToTxnManagerTest.java | 5 +-
.../kafka/storage/internals/log/LogConfig.java | 9 +-
.../kafka/storage/internals/log/UnifiedLog.java | 19 ++++-
.../org/apache/kafka/streams/StreamsConfig.java | 7 +-
.../processor/internals/StateDirectoryTest.java | 6 +-
.../internals/TimeOrderedKeyValueBufferTest.java | 2 +-
.../streams/processor/MockProcessorContext.java | 2 +-
.../processor/api/MockProcessorContext.java | 2 +-
.../streams/test/MockProcessorContextAPITest.java | 4 +-
.../test/MockProcessorContextStateStoreTest.java | 2 +-
.../kafka/tools/BrokerApiVersionsCommand.java | 2 +-
.../apache/kafka/tools/MetadataQuorumCommand.java | 5 +-
.../org/apache/kafka/tools/TopicCommandTest.java | 2 +-
99 files changed, 684 insertions(+), 308 deletions(-)
