"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "monasca_api/conf/kafka.py" between
monasca-api-3.1.0.tar.gz and monasca-api-4.0.0.tar.gz

About: OpenStack Monasca API is a RESTful API server that is designed with a layered architecture and supports Monitoring as a Service (MONaaS).
The "Ussuri" series (latest release).

kafka.py  (monasca-api-3.1.0):kafka.py  (monasca-api-4.0.0)
skipping to change at line 67 skipping to change at line 67
help='The partitions this connection should listen for ' help='The partitions this connection should listen for '
'messages on. (NOT USED)'), 'messages on. (NOT USED)'),
cfg.BoolOpt('drop_data', default=False, cfg.BoolOpt('drop_data', default=False,
help='Specify if received data should be simply dropped. ' help='Specify if received data should be simply dropped. '
'This parameter is only for testing purposes. (NOT USED)'), 'This parameter is only for testing purposes. (NOT USED)'),
cfg.BoolOpt(name='legacy_kafka_client_enabled', default=True, cfg.BoolOpt(name='legacy_kafka_client_enabled', default=True,
required=True, advanced=True, required=True, advanced=True,
help='Enable legacy Kafka client. When set old version of ' help='Enable legacy Kafka client. When set old version of '
'kafka-python library is used. Message format version ' 'kafka-python library is used. Message format version '
'for the brokers should be set to 0.9.0.0 to avoid ' 'for the brokers should be set to 0.9.0.0 to avoid '
'performance issues until all consumers are upgraded.') 'performance issues until all consumers are upgraded.'),
cfg.IntOpt('queue_buffering_max_messages', default=1000,
help='The maximum number of metrics per payload sent to '
'Kafka. Posts to the Monasca API which exceed this will '
'be chunked into batches not exceeding this number.')
] ]
kafka_group = cfg.OptGroup(name='kafka', title='kafka') kafka_group = cfg.OptGroup(name='kafka', title='kafka')
def register_opts(conf): def register_opts(conf):
conf.register_group(kafka_group) conf.register_group(kafka_group)
conf.register_opts(kafka_opts, kafka_group) conf.register_opts(kafka_opts, kafka_group)
def list_opts(): def list_opts():
return kafka_group, kafka_opts return kafka_group, kafka_opts
 End of changes. 1 change blocks. 
1 lines changed or deleted 5 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)