kafka: Remove unused connection pool options
These options were deprecated 7 years ago[1] and have been unused since then. [1] 1ccdccddaa838a4715fd21e8eb67e207d172c240 Change-Id: I75f85cf25e4fc3cb027386d479f2da4765e5bb8b
This commit is contained in:
parent
0deb682868
commit
be7d74b334
@ -18,71 +18,43 @@ from oslo_messaging._drivers import common
|
|||||||
KAFKA_OPTS = [
|
KAFKA_OPTS = [
|
||||||
cfg.IntOpt('kafka_max_fetch_bytes', default=1024 * 1024,
|
cfg.IntOpt('kafka_max_fetch_bytes', default=1024 * 1024,
|
||||||
help='Max fetch bytes of Kafka consumer'),
|
help='Max fetch bytes of Kafka consumer'),
|
||||||
|
|
||||||
cfg.FloatOpt('kafka_consumer_timeout', default=1.0,
|
cfg.FloatOpt('kafka_consumer_timeout', default=1.0,
|
||||||
help='Default timeout(s) for Kafka consumers'),
|
help='Default timeout(s) for Kafka consumers'),
|
||||||
|
|
||||||
cfg.IntOpt('pool_size', default=10,
|
|
||||||
deprecated_for_removal=True,
|
|
||||||
deprecated_reason='Driver no longer uses connection pool. ',
|
|
||||||
help='Pool Size for Kafka Consumers'),
|
|
||||||
|
|
||||||
cfg.IntOpt('conn_pool_min_size', default=2,
|
|
||||||
deprecated_for_removal=True,
|
|
||||||
deprecated_reason='Driver no longer uses connection pool. ',
|
|
||||||
help='The pool size limit for connections expiration policy'),
|
|
||||||
|
|
||||||
cfg.IntOpt('conn_pool_ttl', default=1200,
|
|
||||||
deprecated_for_removal=True,
|
|
||||||
deprecated_reason='Driver no longer uses connection pool. ',
|
|
||||||
help='The time-to-live in sec of idle connections in the pool'),
|
|
||||||
|
|
||||||
cfg.StrOpt('consumer_group', default="oslo_messaging_consumer",
|
cfg.StrOpt('consumer_group', default="oslo_messaging_consumer",
|
||||||
help='Group id for Kafka consumer. Consumers in one group '
|
help='Group id for Kafka consumer. Consumers in one group '
|
||||||
'will coordinate message consumption'),
|
'will coordinate message consumption'),
|
||||||
|
|
||||||
cfg.FloatOpt('producer_batch_timeout', default=0.,
|
cfg.FloatOpt('producer_batch_timeout', default=0.,
|
||||||
help="Upper bound on the delay for KafkaProducer batching "
|
help="Upper bound on the delay for KafkaProducer batching "
|
||||||
"in seconds"),
|
"in seconds"),
|
||||||
|
|
||||||
cfg.IntOpt('producer_batch_size', default=16384,
|
cfg.IntOpt('producer_batch_size', default=16384,
|
||||||
help='Size of batch for the producer async send'),
|
help='Size of batch for the producer async send'),
|
||||||
|
|
||||||
cfg.StrOpt('compression_codec', default='none',
|
cfg.StrOpt('compression_codec', default='none',
|
||||||
choices=['none', 'gzip', 'snappy', 'lz4', 'zstd'],
|
choices=['none', 'gzip', 'snappy', 'lz4', 'zstd'],
|
||||||
help='The compression codec for all data generated by the '
|
help='The compression codec for all data generated by the '
|
||||||
'producer. If not set, compression will not be used. '
|
'producer. If not set, compression will not be used. '
|
||||||
'Note that the allowed values of this depend on the kafka '
|
'Note that the allowed values of this depend on the kafka '
|
||||||
'version'),
|
'version'),
|
||||||
|
|
||||||
cfg.BoolOpt('enable_auto_commit',
|
cfg.BoolOpt('enable_auto_commit',
|
||||||
default=False,
|
default=False,
|
||||||
help='Enable asynchronous consumer commits'),
|
help='Enable asynchronous consumer commits'),
|
||||||
|
|
||||||
cfg.IntOpt('max_poll_records', default=500,
|
cfg.IntOpt('max_poll_records', default=500,
|
||||||
help='The maximum number of records returned in a poll call'),
|
help='The maximum number of records returned in a poll call'),
|
||||||
|
|
||||||
cfg.StrOpt('security_protocol', default='PLAINTEXT',
|
cfg.StrOpt('security_protocol', default='PLAINTEXT',
|
||||||
choices=('PLAINTEXT', 'SASL_PLAINTEXT', 'SSL', 'SASL_SSL'),
|
choices=('PLAINTEXT', 'SASL_PLAINTEXT', 'SSL', 'SASL_SSL'),
|
||||||
help='Protocol used to communicate with brokers'),
|
help='Protocol used to communicate with brokers'),
|
||||||
|
|
||||||
cfg.StrOpt('sasl_mechanism',
|
cfg.StrOpt('sasl_mechanism',
|
||||||
default='PLAIN',
|
default='PLAIN',
|
||||||
help='Mechanism when security protocol is SASL'),
|
help='Mechanism when security protocol is SASL'),
|
||||||
|
|
||||||
cfg.StrOpt('ssl_cafile',
|
cfg.StrOpt('ssl_cafile',
|
||||||
default='',
|
default='',
|
||||||
help='CA certificate PEM file used to verify the server'
|
help='CA certificate PEM file used to verify the server'
|
||||||
' certificate'),
|
' certificate'),
|
||||||
|
|
||||||
cfg.StrOpt('ssl_client_cert_file',
|
cfg.StrOpt('ssl_client_cert_file',
|
||||||
default='',
|
default='',
|
||||||
help='Client certificate PEM file used for authentication.'),
|
help='Client certificate PEM file used for authentication.'),
|
||||||
|
|
||||||
cfg.StrOpt('ssl_client_key_file',
|
cfg.StrOpt('ssl_client_key_file',
|
||||||
default='',
|
default='',
|
||||||
help='Client key PEM file used for authentication.'),
|
help='Client key PEM file used for authentication.'),
|
||||||
|
|
||||||
cfg.StrOpt('ssl_client_key_password',
|
cfg.StrOpt('ssl_client_key_password',
|
||||||
default='',
|
default='',
|
||||||
help='Client key password file used for authentication.')
|
help='Client key password file used for authentication.')
|
||||||
|
@ -0,0 +1,9 @@
|
|||||||
|
---
|
||||||
|
upgrade:
|
||||||
|
- |
|
||||||
|
The following deprecated options in the ``[oslo_messaging_kafka]`` section
|
||||||
|
have been removed.
|
||||||
|
|
||||||
|
- ``pool_size``
|
||||||
|
- ``conn_pool_min_size``
|
||||||
|
- ``conn_pool_ttl``
|
Loading…
x
Reference in New Issue
Block a user