Page History

...

The implementation class of AbstractConfig involved in changes

The bold methods and classes in bold mentioned below all need to be newly created.

1. AdminClientConfig

   config	validator
   security.protocol	in(SecurityProtocol.names().toArray(newString[0]))

   
   
   

2. ConsumerConfig

   config	validator
   group.instance.id	newConfigDef.NonEmptyString()
   key.deserializer	newConfigDef.NonNullValidator()
   value.deserializer	newConfigDef.NonNullValidator()
   security.protocol	in(SecurityProtocol.names().toArray(newString[0]))

   
   
   

3. ProducerConfig

   config	validator
   key.serializer	newConfigDef.NonNullValidator()
   value.serializer	newConfigDef.NonNullValidator()
   security.protocol	in(SecurityProtocol.names().toArray(newString[0]))
   compression.type	in(CompressionType.names().toArray(newString[0]))

   
   
   

4. SaslConfigs

   config	validator
   sasl.mechanism	newConfigDef.NonNullAndEmptyString()

   
   
   

5. MirrorClientConfig

   config	validator
   security.protocol	in(SecurityProtocol.names().toArray(newString[0]))

   
   
   

6. MirrorConnectorConfig

   config	validator
   security.protocol	in(SecurityProtocol.names().toArray(newString[0]))

   
   
   

7. MirrorMakerConfig

   config	validator
   security.protocol	in(SecurityProtocol.names().toArray(newString[0]))

   
   
   

8. WorkerConfig

   config	validator
   ssl.client.auth	in(SslClientAuth.names().toArray(newString[0]))

   
   
   

9. DistributedConfig

   config	validator
   security.protocol	in(SecurityProtocol.names().toArray(newString[0]))

   
   
   

10. KafkaConfig

    config	validator
    sasl.mechanism.controller.protocol	newConfigDef.NonNullAndEmptyString()
    authorizer.class.name	new ConfigDef.NonNullValidator()
    security.inter.broker.protocol	in(SecurityProtocol.names().toArray(new Array[String](0)):_*)
    sasl.mechanism.inter.broker.protocol	newConfigDef.NonNullAndEmptyString()
    sasl.enabled.mechanisms	newBrokerSecurityConfigs.SaslEnabledMechanismsValidator()
    compression.type	in(BrokerCompressionCodec.brokerCompressionOptions:_*)

    
    
    

11. StreamsConfig

    config	validator
    security.protocol	in(SecurityProtocol.names().toArray(newString[0]))

    
    

...