On 14/02/17 02:52 PM, Elancheran Subramanian wrote: > Hello All, > This is reg limiting the number of retries for Kafka driver support on > Nova and Neutron. > > While trying out the oslo messaging notifications support for Kafka on > Nova and Neutron, the Kafka driver doesn’t support limiting the number > of retries for failed messages. When I checked the code, currently there > is no configuration which support that, though the send_notification has > retry https://github.com/openstack/oslo.messaging/blob/master/oslo_messaging/_drivers/impl_kafka.py#L336 but > it’s not set or passed from component’s (nova or neutron’s) > configuration. Is there any configuration which I’m missing? Please let > me know. > disclaimer: i didn't try the following... you should be able to pass a retry value from when you create Notifier obj. like ceilometer[1]... i don't think nova uses it[2]. [1] https://github.com/openstack/ceilometer/blob/master/ceilometer/publisher/messaging.py#L205 [2] https://github.com/openstack/nova/blob/8557aaeb2f3818de352ce7d0b7bf62d74ddffc4e/nova/rpc.py#L82-L98 cheers, -- gord