bq. There is a --delete-config option

Consider adding a sample with the above option to the KIP.

Thanks

On Mon, Nov 20, 2017 at 11:36 AM, Rajini Sivaram <rajinisiva...@gmail.com>
wrote:

> Hi Ted,
>
> Thank you for reviewing the KIP.
>
> *Would decreasing network/IO threads be supported ?*
> Yes, As described in the KIP, some connections will be closed if network
> thread count is reduced (and reconnections will be processed on remaining
> threads)
>
> *What if some keys in configs are not in the Set returned
> by reconfigurableConfigs()? Would exception be thrown ?*
> No, *reconfigurableConfigs() *will be used to decide which classes are
> notified when a configuration update is made*. **reconfigure(Map<String, ?>
> configs)* will be invoked with all of the configured configs of the broker,
>  similar to  *configure(Map<String, ?> configs). *For example, when
> *SslChannelBuilder* is made reconfigurable, it could just create a new
> SslFactory with the latest configs, using the same code as *configure()*.
> We avoid reconfiguring *SslChannelBuilder *unnecessarily*, *for example if
> a topic config has changed, since topic configs are not listed in the
> *SslChannelBuilder#**reconfigurableConfigs().*
>
> *The sample commands for bin/kafka-configs include '--add-config'. Would
> there be '--remove-config' ?*
> bin/kafka-configs.sh is an existing tool whose parameters will not be
> modified by this KIP. There is a --delete-config option.
>
> *ssl.keystore.password appears a few lines above. Would there be any
> issue with mixture of connections (with old and new password) ?*
> No, passwords (and the actual keystore) are only used during
> authentication. Any channel created using the old SslFactory will not be
> impacted.
>
> Regards,
>
> Rajini
>
>
> On Mon, Nov 20, 2017 at 4:39 PM, Ted Yu <yuzhih...@gmail.com> wrote:
>
> > bq. (e.g. increase network/IO threads)
> >
> > Would decreasing network/IO threads be supported ?
> >
> > bq.     void reconfigure(Map<String, ?> configs);
> >
> > What if some keys in configs are not in the Set returned by
> > reconfigurableConfigs()
> > ? Would exception be thrown ?
> > If so, please specify which exception would be thrown.
> >
> > The sample commands for bin/kafka-configs include '--add-config'.
> > Would there be '--remove-config' ?
> >
> > bq. Existing connections will not be affected, new connections will use
> the
> > new keystore.
> >
> > ssl.keystore.password appears a few lines above. Would there be any issue
> > with mixture of connections (with old and new password) ?
> >
> >
> > Cheers
> >
> >
> >
> > On Mon, Nov 20, 2017 at 5:57 AM, Rajini Sivaram <rajinisiva...@gmail.com
> >
> > wrote:
> >
> > > Hi all,
> > >
> > > I have submitted KIP-226 to enable dynamic reconfiguration of brokers
> > > without restart:
> > >
> > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-
> > > 226+-+Dynamic+Broker+Configuration
> > >
> > > The KIP proposes to extend the current dynamic replication quota
> > > configuration for brokers to support dynamic reconfiguration of a
> limited
> > > set of configuration options that are typically updated during the
> > lifetime
> > > of a broker.
> > >
> > > Feedback and suggestions are welcome.
> > >
> > > Thank you...
> > >
> > > Regards,
> > >
> > > Rajini
> > >
> >
>

Reply via email to