)]}'
{"doc/source/admin/Kafka.rst":[{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[],"source_content_type":"","patch_set":4,"id":"3f79a3b5_132eb1f7","updated":"2018-12-19 14:38:18.000000000","message":"There\u0027s some whitespace damage here and the filename should be lower case. Could you fix both issues?","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[],"source_content_type":"","patch_set":4,"id":"bfdaf3ff_33bc7cdb","in_reply_to":"3f79a3b5_132eb1f7","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":2,"context_line":"Kafka Driver Deployment Guide"},{"line_number":3,"context_line":"-----------------------------"},{"line_number":4,"context_line":""},{"line_number":5,"context_line":".. currentmodule:: oslo_messaging"},{"line_number":6,"context_line":""},{"line_number":7,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":8,"context_line":"Introduction"}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_9339613e","line":5,"range":{"start_line":5,"start_character":0,"end_line":5,"end_character":33},"updated":"2018-12-19 14:38:18.000000000","message":"Unless you\u0027re using Sphinx\u0027s autodoc directives in here (which you\u0027re not), this isn\u0027t necessary","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":2,"context_line":"Kafka Driver Deployment Guide"},{"line_number":3,"context_line":"-----------------------------"},{"line_number":4,"context_line":""},{"line_number":5,"context_line":".. currentmodule:: oslo_messaging"},{"line_number":6,"context_line":""},{"line_number":7,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":8,"context_line":"Introduction"}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_d3cc108b","line":5,"range":{"start_line":5,"start_character":0,"end_line":5,"end_character":33},"in_reply_to":"3f79a3b5_9339613e","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":9,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":10,"context_line":""},{"line_number":11,"context_line":"The Kafka Driver is an experimental messaging transport backend "},{"line_number":12,"context_line":"in oslo.messaging. The driver maps the base oslo.messaging"},{"line_number":13,"context_line":"capabilities for Notification message exchange onto V2.0 of the"},{"line_number":14,"context_line":"Apache Kafka distributed streaming platform."},{"line_number":15,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_f34f75be","line":12,"range":{"start_line":12,"start_character":3,"end_line":12,"end_character":17},"updated":"2018-12-19 14:38:18.000000000","message":"*oslo.messaging*","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":9,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":10,"context_line":""},{"line_number":11,"context_line":"The Kafka Driver is an experimental messaging transport backend "},{"line_number":12,"context_line":"in oslo.messaging. The driver maps the base oslo.messaging"},{"line_number":13,"context_line":"capabilities for Notification message exchange onto V2.0 of the"},{"line_number":14,"context_line":"Apache Kafka distributed streaming platform."},{"line_number":15,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_93c68867","line":12,"range":{"start_line":12,"start_character":3,"end_line":12,"end_character":17},"in_reply_to":"3f79a3b5_f34f75be","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":10,"context_line":""},{"line_number":11,"context_line":"The Kafka Driver is an experimental messaging transport backend "},{"line_number":12,"context_line":"in oslo.messaging. The driver maps the base oslo.messaging"},{"line_number":13,"context_line":"capabilities for Notification message exchange onto V2.0 of the"},{"line_number":14,"context_line":"Apache Kafka distributed streaming platform."},{"line_number":15,"context_line":""},{"line_number":16,"context_line":"More detail regarding the Apache Kafka server is available from the"}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_b31fbdb7","line":13,"range":{"start_line":13,"start_character":17,"end_line":13,"end_character":29},"updated":"2018-12-19 14:38:18.000000000","message":"Why is this title case? If it\u0027s ``code``, mark it as such. Otherwise, make it lower case here and throughout the rest of the document","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":10,"context_line":""},{"line_number":11,"context_line":"The Kafka Driver is an experimental messaging transport backend "},{"line_number":12,"context_line":"in oslo.messaging. The driver maps the base oslo.messaging"},{"line_number":13,"context_line":"capabilities for Notification message exchange onto V2.0 of the"},{"line_number":14,"context_line":"Apache Kafka distributed streaming platform."},{"line_number":15,"context_line":""},{"line_number":16,"context_line":"More detail regarding the Apache Kafka server is available from the"}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_939be870","line":13,"range":{"start_line":13,"start_character":17,"end_line":13,"end_character":29},"in_reply_to":"3f79a3b5_b31fbdb7","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":14,"context_line":"Apache Kafka distributed streaming platform."},{"line_number":15,"context_line":""},{"line_number":16,"context_line":"More detail regarding the Apache Kafka server is available from the"},{"line_number":17,"context_line":"`Apache Kafka website`_"},{"line_number":18,"context_line":""},{"line_number":19,"context_line":".. _Apache Kafka website: https://kafka.apache.org/"},{"line_number":20,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_5376690d","line":17,"range":{"start_line":17,"start_character":0,"end_line":17,"end_character":23},"updated":"2018-12-19 14:38:18.000000000","message":"pro tip:\n\n    `Apache Kafka website`__.\n\n    __ https://kafka.apache.org/\n\nis much briefer, assuming you\u0027re only referencing things once :)","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":14,"context_line":"Apache Kafka distributed streaming platform."},{"line_number":15,"context_line":""},{"line_number":16,"context_line":"More detail regarding the Apache Kafka server is available from the"},{"line_number":17,"context_line":"`Apache Kafka website`_"},{"line_number":18,"context_line":""},{"line_number":19,"context_line":".. _Apache Kafka website: https://kafka.apache.org/"},{"line_number":20,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_53e260d7","line":17,"range":{"start_line":17,"start_character":0,"end_line":17,"end_character":23},"in_reply_to":"3f79a3b5_5376690d","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":29,"context_line":"Overview"},{"line_number":30,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":31,"context_line":""},{"line_number":32,"context_line":"The Kafka driver is **only** supports use for sending and receiving  "},{"line_number":33,"context_line":"oslo.messaging Notifications. Communications between"},{"line_number":34,"context_line":"the driver and Kafka server backend uses a `binary protocol over TCP`_"},{"line_number":35,"context_line":"that defines all APIs as request response message pairs. The Kafka"}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_531189ad","line":32,"range":{"start_line":32,"start_character":17,"end_line":32,"end_character":20},"updated":"2018-12-19 14:38:18.000000000","message":"drop","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":29,"context_line":"Overview"},{"line_number":30,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":31,"context_line":""},{"line_number":32,"context_line":"The Kafka driver is **only** supports use for sending and receiving  "},{"line_number":33,"context_line":"oslo.messaging Notifications. Communications between"},{"line_number":34,"context_line":"the driver and Kafka server backend uses a `binary protocol over TCP`_"},{"line_number":35,"context_line":"that defines all APIs as request response message pairs. The Kafka"}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_b3d06cf9","line":32,"range":{"start_line":32,"start_character":17,"end_line":32,"end_character":20},"in_reply_to":"3f79a3b5_531189ad","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":46,"context_line":"Hybrid Messaging Deployment"},{"line_number":47,"context_line":"---------------------------"},{"line_number":48,"context_line":""},{"line_number":49,"context_line":"Oslo.messaging provides a mechanism to configure separate backends for"},{"line_number":50,"context_line":"RPC and Notification communications. This is supported through the"},{"line_number":51,"context_line":"definition of separate RPC and Notification `transport urls`_ in the"},{"line_number":52,"context_line":"service configuration. When the Kafka driver is deployed for"}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_535f4973","line":49,"range":{"start_line":49,"start_character":0,"end_line":49,"end_character":14},"updated":"2018-12-19 14:38:18.000000000","message":"*oslo.messaging*","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":46,"context_line":"Hybrid Messaging Deployment"},{"line_number":47,"context_line":"---------------------------"},{"line_number":48,"context_line":""},{"line_number":49,"context_line":"Oslo.messaging provides a mechanism to configure separate backends for"},{"line_number":50,"context_line":"RPC and Notification communications. This is supported through the"},{"line_number":51,"context_line":"definition of separate RPC and Notification `transport urls`_ in the"},{"line_number":52,"context_line":"service configuration. When the Kafka driver is deployed for"}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_332b1cec","line":49,"range":{"start_line":49,"start_character":0,"end_line":49,"end_character":14},"in_reply_to":"3f79a3b5_535f4973","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":50,"context_line":"RPC and Notification communications. This is supported through the"},{"line_number":51,"context_line":"definition of separate RPC and Notification `transport urls`_ in the"},{"line_number":52,"context_line":"service configuration. When the Kafka driver is deployed for"},{"line_number":53,"context_line":"oslo.messaging notifications, a separate driver and messaging backend"},{"line_number":54,"context_line":"must be deployed for RPC communications. For these hybrid messaging"},{"line_number":55,"context_line":"configurations, either the `rabbit`_ or `amqp`_ drivers can be deployed"},{"line_number":56,"context_line":"for oslo.messaging RPC."}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_b34d7dc7","line":53,"range":{"start_line":53,"start_character":0,"end_line":53,"end_character":14},"updated":"2018-12-19 14:38:18.000000000","message":"*oslo.messaging* (and so on)","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":50,"context_line":"RPC and Notification communications. This is supported through the"},{"line_number":51,"context_line":"definition of separate RPC and Notification `transport urls`_ in the"},{"line_number":52,"context_line":"service configuration. When the Kafka driver is deployed for"},{"line_number":53,"context_line":"oslo.messaging notifications, a separate driver and messaging backend"},{"line_number":54,"context_line":"must be deployed for RPC communications. For these hybrid messaging"},{"line_number":55,"context_line":"configurations, either the `rabbit`_ or `amqp`_ drivers can be deployed"},{"line_number":56,"context_line":"for oslo.messaging RPC."}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_f334b44c","line":53,"range":{"start_line":53,"start_character":0,"end_line":53,"end_character":14},"in_reply_to":"3f79a3b5_b34d7dc7","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":71,"context_line":"vhosts. In order to support the presence of a vhost in the transport"},{"line_number":72,"context_line":"url provided to the driver, the topic created on the Kafka server will"},{"line_number":73,"context_line":"be appended with the virtual host name. This creates a unique topic"},{"line_number":74,"context_line":"per for virtual host but **note well** there is otherwise no access"},{"line_number":75,"context_line":"control or isolation provided by the Kafka server. "},{"line_number":76,"context_line":""},{"line_number":77,"context_line":"Listener Pools"}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_33bf2d7a","line":74,"range":{"start_line":74,"start_character":27,"end_line":74,"end_character":36},"updated":"2018-12-19 14:38:18.000000000","message":"note well? Perhaps just \"note\" or \"it\u0027s important to note that\"","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":71,"context_line":"vhosts. In order to support the presence of a vhost in the transport"},{"line_number":72,"context_line":"url provided to the driver, the topic created on the Kafka server will"},{"line_number":73,"context_line":"be appended with the virtual host name. This creates a unique topic"},{"line_number":74,"context_line":"per for virtual host but **note well** there is otherwise no access"},{"line_number":75,"context_line":"control or isolation provided by the Kafka server. "},{"line_number":76,"context_line":""},{"line_number":77,"context_line":"Listener Pools"}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_b3270c13","line":74,"range":{"start_line":74,"start_character":27,"end_line":74,"end_character":36},"in_reply_to":"3f79a3b5_33bf2d7a","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":150,"context_line":"--------------------"},{"line_number":151,"context_line":""},{"line_number":152,"context_line":"In oslo.messaging, the transport_url parameters define the OpenStack service"},{"line_number":153,"context_line":"backends for RPC and Notify. The url is of the form:"},{"line_number":154,"context_line":""},{"line_number":155,"context_line":"    transport://user:pass@host1:port[,hostN:portN]/virtual_host"},{"line_number":156,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_73d845ed","line":153,"range":{"start_line":153,"start_character":51,"end_line":153,"end_character":52},"updated":"2018-12-19 14:38:18.000000000","message":"::","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":150,"context_line":"--------------------"},{"line_number":151,"context_line":""},{"line_number":152,"context_line":"In oslo.messaging, the transport_url parameters define the OpenStack service"},{"line_number":153,"context_line":"backends for RPC and Notify. The url is of the form:"},{"line_number":154,"context_line":""},{"line_number":155,"context_line":"    transport://user:pass@host1:port[,hostN:portN]/virtual_host"},{"line_number":156,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_3379dcfb","line":153,"range":{"start_line":153,"start_character":51,"end_line":153,"end_character":52},"in_reply_to":"3f79a3b5_73d845ed","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":155,"context_line":"    transport://user:pass@host1:port[,hostN:portN]/virtual_host"},{"line_number":156,"context_line":""},{"line_number":157,"context_line":"Where the transport value specifies the rpc or notification backend as"},{"line_number":158,"context_line":"one of amqp, rabbit, **kafka**, etc."},{"line_number":159,"context_line":""},{"line_number":160,"context_line":"To specify and enable the Kafka driver for Notify, in the section"},{"line_number":161,"context_line":"[NOTIFICATIONS] of the service configuration file, specify the"}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_93d5e1b7","line":158,"range":{"start_line":158,"start_character":7,"end_line":158,"end_character":30},"updated":"2018-12-19 14:38:18.000000000","message":"``amqp``, ``rabbbit``, ``kafka``, etc.","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":155,"context_line":"    transport://user:pass@host1:port[,hostN:portN]/virtual_host"},{"line_number":156,"context_line":""},{"line_number":157,"context_line":"Where the transport value specifies the rpc or notification backend as"},{"line_number":158,"context_line":"one of amqp, rabbit, **kafka**, etc."},{"line_number":159,"context_line":""},{"line_number":160,"context_line":"To specify and enable the Kafka driver for Notify, in the section"},{"line_number":161,"context_line":"[NOTIFICATIONS] of the service configuration file, specify the"}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_138858e5","line":158,"range":{"start_line":158,"start_character":7,"end_line":158,"end_character":30},"in_reply_to":"3f79a3b5_93d5e1b7","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":158,"context_line":"one of amqp, rabbit, **kafka**, etc."},{"line_number":159,"context_line":""},{"line_number":160,"context_line":"To specify and enable the Kafka driver for Notify, in the section"},{"line_number":161,"context_line":"[NOTIFICATIONS] of the service configuration file, specify the"},{"line_number":162,"context_line":"\u0027transport_url\u0027 parameter:"},{"line_number":163,"context_line":""},{"line_number":164,"context_line":"::"}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_f3dd35da","line":161,"range":{"start_line":161,"start_character":0,"end_line":161,"end_character":15},"updated":"2018-12-19 14:38:18.000000000","message":"``[NOTIFICATIONS]``","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":158,"context_line":"one of amqp, rabbit, **kafka**, etc."},{"line_number":159,"context_line":""},{"line_number":160,"context_line":"To specify and enable the Kafka driver for Notify, in the section"},{"line_number":161,"context_line":"[NOTIFICATIONS] of the service configuration file, specify the"},{"line_number":162,"context_line":"\u0027transport_url\u0027 parameter:"},{"line_number":163,"context_line":""},{"line_number":164,"context_line":"::"}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_73768409","line":161,"range":{"start_line":161,"start_character":0,"end_line":161,"end_character":15},"in_reply_to":"3f79a3b5_f3dd35da","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":159,"context_line":""},{"line_number":160,"context_line":"To specify and enable the Kafka driver for Notify, in the section"},{"line_number":161,"context_line":"[NOTIFICATIONS] of the service configuration file, specify the"},{"line_number":162,"context_line":"\u0027transport_url\u0027 parameter:"},{"line_number":163,"context_line":""},{"line_number":164,"context_line":"::"},{"line_number":165,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_d3f8394c","line":162,"range":{"start_line":162,"start_character":25,"end_line":162,"end_character":26},"updated":"2018-12-19 14:38:18.000000000","message":"If you use \u0027::\u0027 here, you can drop the one on the line below","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":159,"context_line":""},{"line_number":160,"context_line":"To specify and enable the Kafka driver for Notify, in the section"},{"line_number":161,"context_line":"[NOTIFICATIONS] of the service configuration file, specify the"},{"line_number":162,"context_line":"\u0027transport_url\u0027 parameter:"},{"line_number":163,"context_line":""},{"line_number":164,"context_line":"::"},{"line_number":165,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_13e311a1","line":162,"range":{"start_line":162,"start_character":1,"end_line":162,"end_character":14},"updated":"2018-12-19 14:38:18.000000000","message":"``transport_url``","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":159,"context_line":""},{"line_number":160,"context_line":"To specify and enable the Kafka driver for Notify, in the section"},{"line_number":161,"context_line":"[NOTIFICATIONS] of the service configuration file, specify the"},{"line_number":162,"context_line":"\u0027transport_url\u0027 parameter:"},{"line_number":163,"context_line":""},{"line_number":164,"context_line":"::"},{"line_number":165,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_13d618c7","line":162,"range":{"start_line":162,"start_character":1,"end_line":162,"end_character":14},"in_reply_to":"3f79a3b5_13e311a1","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":166,"context_line":"  [NOTIFICATIONS]"},{"line_number":167,"context_line":"  transport_url \u003d kafka://username:password@kafkahostname:9092"},{"line_number":168,"context_line":""},{"line_number":169,"context_line":"Note, that if a \u0027transport_url\u0027 parameter is not specified in the"},{"line_number":170,"context_line":"[NOTIFICATIONS] section, the [DEFAULT] transport_url will be used"},{"line_number":171,"context_line":"for both RPC and Notify backends."},{"line_number":172,"context_line":""},{"line_number":173,"context_line":"Driver Options"},{"line_number":174,"context_line":"--------------"}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_73f12565","line":171,"range":{"start_line":169,"start_character":0,"end_line":171,"end_character":33},"updated":"2018-12-19 14:38:18.000000000","message":"Appropriate ``literals`` here","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":166,"context_line":"  [NOTIFICATIONS]"},{"line_number":167,"context_line":"  transport_url \u003d kafka://username:password@kafkahostname:9092"},{"line_number":168,"context_line":""},{"line_number":169,"context_line":"Note, that if a \u0027transport_url\u0027 parameter is not specified in the"},{"line_number":170,"context_line":"[NOTIFICATIONS] section, the [DEFAULT] transport_url will be used"},{"line_number":171,"context_line":"for both RPC and Notify backends."},{"line_number":172,"context_line":""},{"line_number":173,"context_line":"Driver Options"},{"line_number":174,"context_line":"--------------"}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_33c79c15","line":171,"range":{"start_line":169,"start_character":0,"end_line":171,"end_character":33},"in_reply_to":"3f79a3b5_73f12565","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":175,"context_line":""},{"line_number":176,"context_line":"It is recommended that the default configuration options provided by"},{"line_number":177,"context_line":"the Kafka driver be used. The configuration options can be modified"},{"line_number":178,"context_line":"in the oslo_messaging_kafka section of the service configuration file."},{"line_number":179,"context_line":""},{"line_number":180,"context_line":"Consumer Options"},{"line_number":181,"context_line":"^^^^^^^^^^^^^^^^"}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_93ee4182","line":178,"range":{"start_line":178,"start_character":7,"end_line":178,"end_character":27},"updated":"2018-12-19 14:38:18.000000000","message":"``literal``","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":175,"context_line":""},{"line_number":176,"context_line":"It is recommended that the default configuration options provided by"},{"line_number":177,"context_line":"the Kafka driver be used. The configuration options can be modified"},{"line_number":178,"context_line":"in the oslo_messaging_kafka section of the service configuration file."},{"line_number":179,"context_line":""},{"line_number":180,"context_line":"Consumer Options"},{"line_number":181,"context_line":"^^^^^^^^^^^^^^^^"}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_93e1a89d","line":178,"range":{"start_line":178,"start_character":7,"end_line":178,"end_character":27},"in_reply_to":"3f79a3b5_93ee4182","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":180,"context_line":"Consumer Options"},{"line_number":181,"context_line":"^^^^^^^^^^^^^^^^"},{"line_number":182,"context_line":""},{"line_number":183,"context_line":"#. kafka_max_fetch_bytes: Initial maximum number of byters per"},{"line_number":184,"context_line":"   topic+partition to request when fetching messages from the broker."},{"line_number":185,"context_line":""},{"line_number":186,"context_line":"#. kafka_consumer_timeout: Consumer polling interval timeout"},{"line_number":187,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_b3801d9f","line":184,"range":{"start_line":183,"start_character":0,"end_line":184,"end_character":69},"updated":"2018-12-19 14:38:18.000000000","message":"Consider making this a definition list:\n\n    ``kafka_max_fetch_bytes``\n      Initial maximum number of byters per ...\n\n(note that there has to be an indent for the definition but there should not be an empty line between the term and definition)\n\nDitto for below.","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":180,"context_line":"Consumer Options"},{"line_number":181,"context_line":"^^^^^^^^^^^^^^^^"},{"line_number":182,"context_line":""},{"line_number":183,"context_line":"#. kafka_max_fetch_bytes: Initial maximum number of byters per"},{"line_number":184,"context_line":"   topic+partition to request when fetching messages from the broker."},{"line_number":185,"context_line":""},{"line_number":186,"context_line":"#. kafka_consumer_timeout: Consumer polling interval timeout"},{"line_number":187,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_a8123a57","line":184,"range":{"start_line":183,"start_character":0,"end_line":184,"end_character":69},"in_reply_to":"3f79a3b5_b3801d9f","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"ea0f6e85c4e65b518abcee998ce8a3024c38c0f2","unresolved":false,"context_lines":[{"line_number":226,"context_line":"DevStack. As the Kafka driver can only be deployed for notifications,"},{"line_number":227,"context_line":"the plugin suports the deployment of several message bus configurations."},{"line_number":228,"context_line":""},{"line_number":229,"context_line":"In local.conf [localrc] section, the `devstack-plugin-kafka`_  plugin"},{"line_number":230,"context_line":"repository must be enabled. For example:"},{"line_number":231,"context_line":""},{"line_number":232,"context_line":"::"}],"source_content_type":"text/x-rst","patch_set":4,"id":"3f79a3b5_738605bb","line":229,"range":{"start_line":229,"start_character":3,"end_line":229,"end_character":23},"updated":"2018-12-19 14:38:18.000000000","message":":file:`local.conf` ``[localrc]``","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"95ca3a6b33220e983ea2bc07e8cdd27fde2bf5ca","unresolved":false,"context_lines":[{"line_number":226,"context_line":"DevStack. As the Kafka driver can only be deployed for notifications,"},{"line_number":227,"context_line":"the plugin suports the deployment of several message bus configurations."},{"line_number":228,"context_line":""},{"line_number":229,"context_line":"In local.conf [localrc] section, the `devstack-plugin-kafka`_  plugin"},{"line_number":230,"context_line":"repository must be enabled. For example:"},{"line_number":231,"context_line":""},{"line_number":232,"context_line":"::"}],"source_content_type":"text/x-rst","patch_set":4,"id":"bfdaf3ff_083a6635","line":229,"range":{"start_line":229,"start_character":3,"end_line":229,"end_character":23},"in_reply_to":"3f79a3b5_738605bb","updated":"2019-01-14 16:50:53.000000000","message":"Done","commit_id":"17fa6084fdf395d308af8824753b19dfe0921c21"}],"doc/source/admin/kafka.rst":[{"author":{"_account_id":8770,"name":"Ken Giusti","email":"kgiusti@gmail.com","username":"kgiusti"},"change_message_id":"abc41193dd3ef3f9e5bc89d6d67a9f8e2a8b8f8d","unresolved":false,"context_lines":[{"line_number":26,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":27,"context_line":""},{"line_number":28,"context_line":"The Kafka driver **only** supports use for sending and receiving"},{"line_number":29,"context_line":"*oslo.messaging* notifications. Communications between"},{"line_number":30,"context_line":"the driver and Kafka server backend uses a binary protocol over TCP"},{"line_number":31,"context_line":"that defines all APIs as request response message pairs. The Kafka"},{"line_number":32,"context_line":"driver integrates the confluent kafka python client for full"}],"source_content_type":"text/x-rst","patch_set":5,"id":"bfdaf3ff_a7545954","line":29,"range":{"start_line":29,"start_character":17,"end_line":29,"end_character":30},"updated":"2019-01-17 19:22:55.000000000","message":"Can you add a sentence here that explicitly says kafka does not support RPC messaging?","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"9d52202c64255825218b69d7ba62d130987bc3b5","unresolved":false,"context_lines":[{"line_number":26,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":27,"context_line":""},{"line_number":28,"context_line":"The Kafka driver **only** supports use for sending and receiving"},{"line_number":29,"context_line":"*oslo.messaging* notifications. Communications between"},{"line_number":30,"context_line":"the driver and Kafka server backend uses a binary protocol over TCP"},{"line_number":31,"context_line":"that defines all APIs as request response message pairs. The Kafka"},{"line_number":32,"context_line":"driver integrates the confluent kafka python client for full"}],"source_content_type":"text/x-rst","patch_set":5,"id":"9fdfeff1_d62152fd","line":29,"range":{"start_line":29,"start_character":17,"end_line":29,"end_character":30},"in_reply_to":"bfdaf3ff_a7545954","updated":"2019-01-23 13:27:27.000000000","message":"Done","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":8770,"name":"Ken Giusti","email":"kgiusti@gmail.com","username":"kgiusti"},"change_message_id":"abc41193dd3ef3f9e5bc89d6d67a9f8e2a8b8f8d","unresolved":false,"context_lines":[{"line_number":38,"context_line":"Hybrid Messaging Deployment"},{"line_number":39,"context_line":"---------------------------"},{"line_number":40,"context_line":""},{"line_number":41,"context_line":"*Oslo.messaging* provides a mechanism to configure separate backends for"},{"line_number":42,"context_line":"RPC and notification communications. This is supported through the"},{"line_number":43,"context_line":"definition of separate RPC and notification `transport urls`_ in the"},{"line_number":44,"context_line":"service configuration. When the Kafka driver is deployed for"}],"source_content_type":"text/x-rst","patch_set":5,"id":"bfdaf3ff_87e835e2","line":41,"range":{"start_line":41,"start_character":51,"end_line":41,"end_character":59},"updated":"2019-01-17 19:22:55.000000000","message":"\"separate messaging backends\"","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"9d52202c64255825218b69d7ba62d130987bc3b5","unresolved":false,"context_lines":[{"line_number":38,"context_line":"Hybrid Messaging Deployment"},{"line_number":39,"context_line":"---------------------------"},{"line_number":40,"context_line":""},{"line_number":41,"context_line":"*Oslo.messaging* provides a mechanism to configure separate backends for"},{"line_number":42,"context_line":"RPC and notification communications. This is supported through the"},{"line_number":43,"context_line":"definition of separate RPC and notification `transport urls`_ in the"},{"line_number":44,"context_line":"service configuration. When the Kafka driver is deployed for"}],"source_content_type":"text/x-rst","patch_set":5,"id":"9fdfeff1_b67cceeb","line":41,"range":{"start_line":41,"start_character":51,"end_line":41,"end_character":59},"in_reply_to":"bfdaf3ff_87e835e2","updated":"2019-01-23 13:27:27.000000000","message":"Done","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":8770,"name":"Ken Giusti","email":"kgiusti@gmail.com","username":"kgiusti"},"change_message_id":"abc41193dd3ef3f9e5bc89d6d67a9f8e2a8b8f8d","unresolved":false,"context_lines":[{"line_number":63,"context_line":"vhosts. In order to support the presence of a vhost in the transport"},{"line_number":64,"context_line":"url provided to the driver, the topic created on the Kafka server will"},{"line_number":65,"context_line":"be appended with the virtual host name. This creates a unique topic"},{"line_number":66,"context_line":"per for virtual host but **note** there is otherwise no access"},{"line_number":67,"context_line":"control or isolation provided by the Kafka server."},{"line_number":68,"context_line":""},{"line_number":69,"context_line":"Listener Pools"}],"source_content_type":"text/x-rst","patch_set":5,"id":"bfdaf3ff_a7ce997f","line":66,"range":{"start_line":66,"start_character":0,"end_line":66,"end_character":7},"updated":"2019-01-17 19:22:55.000000000","message":"?","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"9d52202c64255825218b69d7ba62d130987bc3b5","unresolved":false,"context_lines":[{"line_number":63,"context_line":"vhosts. In order to support the presence of a vhost in the transport"},{"line_number":64,"context_line":"url provided to the driver, the topic created on the Kafka server will"},{"line_number":65,"context_line":"be appended with the virtual host name. This creates a unique topic"},{"line_number":66,"context_line":"per for virtual host but **note** there is otherwise no access"},{"line_number":67,"context_line":"control or isolation provided by the Kafka server."},{"line_number":68,"context_line":""},{"line_number":69,"context_line":"Listener Pools"}],"source_content_type":"text/x-rst","patch_set":5,"id":"9fdfeff1_768666de","line":66,"range":{"start_line":66,"start_character":0,"end_line":66,"end_character":7},"in_reply_to":"bfdaf3ff_a7ce997f","updated":"2019-01-23 13:27:27.000000000","message":"Done","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":8770,"name":"Ken Giusti","email":"kgiusti@gmail.com","username":"kgiusti"},"change_message_id":"abc41193dd3ef3f9e5bc89d6d67a9f8e2a8b8f8d","unresolved":false,"context_lines":[{"line_number":101,"context_line":"Protocol Engine"},{"line_number":102,"context_line":"---------------"},{"line_number":103,"context_line":""},{"line_number":104,"context_line":"The Kafka driver is only supported for use as a notification driver"},{"line_number":105,"context_line":"for sending and receiving notifications via *oslo.messaging*."},{"line_number":106,"context_line":"Communications between the driver and Kafka serverbackend uses a"},{"line_number":107,"context_line":"`binary protocol over TCP`_ that defines all APIs as request response"},{"line_number":108,"context_line":"message pairs."},{"line_number":109,"context_line":""},{"line_number":110,"context_line":".. _binary protocol over TCP: https://kafka.apache.org/protocol.html"},{"line_number":111,"context_line":""}],"source_content_type":"text/x-rst","patch_set":5,"id":"bfdaf3ff_4746cdc2","line":108,"range":{"start_line":104,"start_character":0,"end_line":108,"end_character":14},"updated":"2019-01-17 19:22:55.000000000","message":"redundant with respect to the introduction.  Maybe get rid of this instance and update the introduction with a link to the kafka protocol page?","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"9d52202c64255825218b69d7ba62d130987bc3b5","unresolved":false,"context_lines":[{"line_number":101,"context_line":"Protocol Engine"},{"line_number":102,"context_line":"---------------"},{"line_number":103,"context_line":""},{"line_number":104,"context_line":"The Kafka driver is only supported for use as a notification driver"},{"line_number":105,"context_line":"for sending and receiving notifications via *oslo.messaging*."},{"line_number":106,"context_line":"Communications between the driver and Kafka serverbackend uses a"},{"line_number":107,"context_line":"`binary protocol over TCP`_ that defines all APIs as request response"},{"line_number":108,"context_line":"message pairs."},{"line_number":109,"context_line":""},{"line_number":110,"context_line":".. _binary protocol over TCP: https://kafka.apache.org/protocol.html"},{"line_number":111,"context_line":""}],"source_content_type":"text/x-rst","patch_set":5,"id":"9fdfeff1_16891ac9","line":108,"range":{"start_line":104,"start_character":0,"end_line":108,"end_character":14},"in_reply_to":"bfdaf3ff_4746cdc2","updated":"2019-01-23 13:27:27.000000000","message":"Done","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":8770,"name":"Ken Giusti","email":"kgiusti@gmail.com","username":"kgiusti"},"change_message_id":"abc41193dd3ef3f9e5bc89d6d67a9f8e2a8b8f8d","unresolved":false,"context_lines":[{"line_number":144,"context_line":""},{"line_number":145,"context_line":"Where the transport value specifies the rpc or notification backend as"},{"line_number":146,"context_line":"one of ``amqp``, ``rabbit``, ``kafka``, etc. To specify and enable the"},{"line_number":147,"context_line":"Kafka driver for Notify, in the section ``[NOTIFICATIONS]`` of the service"},{"line_number":148,"context_line":"configuration file, specify the ``transport_url`` parameter::"},{"line_number":149,"context_line":""},{"line_number":150,"context_line":"  [NOTIFICATIONS]"}],"source_content_type":"text/x-rst","patch_set":5,"id":"bfdaf3ff_671c31c1","line":147,"range":{"start_line":147,"start_character":17,"end_line":147,"end_character":23},"updated":"2019-01-17 19:22:55.000000000","message":"Notifications","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"9d52202c64255825218b69d7ba62d130987bc3b5","unresolved":false,"context_lines":[{"line_number":144,"context_line":""},{"line_number":145,"context_line":"Where the transport value specifies the rpc or notification backend as"},{"line_number":146,"context_line":"one of ``amqp``, ``rabbit``, ``kafka``, etc. To specify and enable the"},{"line_number":147,"context_line":"Kafka driver for Notify, in the section ``[NOTIFICATIONS]`` of the service"},{"line_number":148,"context_line":"configuration file, specify the ``transport_url`` parameter::"},{"line_number":149,"context_line":""},{"line_number":150,"context_line":"  [NOTIFICATIONS]"}],"source_content_type":"text/x-rst","patch_set":5,"id":"9fdfeff1_9663ca1a","line":147,"range":{"start_line":147,"start_character":17,"end_line":147,"end_character":23},"in_reply_to":"bfdaf3ff_671c31c1","updated":"2019-01-23 13:27:27.000000000","message":"Done","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":8770,"name":"Ken Giusti","email":"kgiusti@gmail.com","username":"kgiusti"},"change_message_id":"abc41193dd3ef3f9e5bc89d6d67a9f8e2a8b8f8d","unresolved":false,"context_lines":[{"line_number":147,"context_line":"Kafka driver for Notify, in the section ``[NOTIFICATIONS]`` of the service"},{"line_number":148,"context_line":"configuration file, specify the ``transport_url`` parameter::"},{"line_number":149,"context_line":""},{"line_number":150,"context_line":"  [NOTIFICATIONS]"},{"line_number":151,"context_line":"  transport_url \u003d kafka://username:password@kafkahostname:9092"},{"line_number":152,"context_line":""},{"line_number":153,"context_line":"Note, that if a ``transport_url`` parameter is not specified in the"}],"source_content_type":"text/x-rst","patch_set":5,"id":"bfdaf3ff_07644549","line":150,"range":{"start_line":150,"start_character":3,"end_line":150,"end_character":16},"updated":"2019-01-17 19:22:55.000000000","message":"[oslo_messaging_notifications]","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"9d52202c64255825218b69d7ba62d130987bc3b5","unresolved":false,"context_lines":[{"line_number":147,"context_line":"Kafka driver for Notify, in the section ``[NOTIFICATIONS]`` of the service"},{"line_number":148,"context_line":"configuration file, specify the ``transport_url`` parameter::"},{"line_number":149,"context_line":""},{"line_number":150,"context_line":"  [NOTIFICATIONS]"},{"line_number":151,"context_line":"  transport_url \u003d kafka://username:password@kafkahostname:9092"},{"line_number":152,"context_line":""},{"line_number":153,"context_line":"Note, that if a ``transport_url`` parameter is not specified in the"}],"source_content_type":"text/x-rst","patch_set":5,"id":"9fdfeff1_f6a6d653","line":150,"range":{"start_line":150,"start_character":3,"end_line":150,"end_character":16},"in_reply_to":"bfdaf3ff_07644549","updated":"2019-01-23 13:27:27.000000000","message":"Done","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":8770,"name":"Ken Giusti","email":"kgiusti@gmail.com","username":"kgiusti"},"change_message_id":"abc41193dd3ef3f9e5bc89d6d67a9f8e2a8b8f8d","unresolved":false,"context_lines":[{"line_number":151,"context_line":"  transport_url \u003d kafka://username:password@kafkahostname:9092"},{"line_number":152,"context_line":""},{"line_number":153,"context_line":"Note, that if a ``transport_url`` parameter is not specified in the"},{"line_number":154,"context_line":"``[NOTIFICATIONS]`` section, the ``[DEFAULT]`` transport_url will be used"},{"line_number":155,"context_line":"for both RPC and Notify backends."},{"line_number":156,"context_line":""},{"line_number":157,"context_line":"Driver Options"}],"source_content_type":"text/x-rst","patch_set":5,"id":"bfdaf3ff_c7595d8e","line":154,"range":{"start_line":154,"start_character":3,"end_line":154,"end_character":16},"updated":"2019-01-17 19:22:55.000000000","message":"ditto above","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"9d52202c64255825218b69d7ba62d130987bc3b5","unresolved":false,"context_lines":[{"line_number":151,"context_line":"  transport_url \u003d kafka://username:password@kafkahostname:9092"},{"line_number":152,"context_line":""},{"line_number":153,"context_line":"Note, that if a ``transport_url`` parameter is not specified in the"},{"line_number":154,"context_line":"``[NOTIFICATIONS]`` section, the ``[DEFAULT]`` transport_url will be used"},{"line_number":155,"context_line":"for both RPC and Notify backends."},{"line_number":156,"context_line":""},{"line_number":157,"context_line":"Driver Options"}],"source_content_type":"text/x-rst","patch_set":5,"id":"9fdfeff1_b6660e29","line":154,"range":{"start_line":154,"start_character":3,"end_line":154,"end_character":16},"in_reply_to":"bfdaf3ff_c7595d8e","updated":"2019-01-23 13:27:27.000000000","message":"Done","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":8770,"name":"Ken Giusti","email":"kgiusti@gmail.com","username":"kgiusti"},"change_message_id":"abc41193dd3ef3f9e5bc89d6d67a9f8e2a8b8f8d","unresolved":false,"context_lines":[{"line_number":161,"context_line":"the Kafka driver be used. The configuration options can be modified"},{"line_number":162,"context_line":"in the ``oslo_messaging_kafka`` section of the service configuration file."},{"line_number":163,"context_line":""},{"line_number":164,"context_line":"Consumer Options"},{"line_number":165,"context_line":"^^^^^^^^^^^^^^^^"},{"line_number":166,"context_line":""},{"line_number":167,"context_line":"kafka_max_fetch_bytes"}],"source_content_type":"text/x-rst","patch_set":5,"id":"bfdaf3ff_c7ce3d2c","line":164,"range":{"start_line":164,"start_character":0,"end_line":164,"end_character":8},"updated":"2019-01-17 19:22:55.000000000","message":"should this be \"Notification Listener Options\"?","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"9d52202c64255825218b69d7ba62d130987bc3b5","unresolved":false,"context_lines":[{"line_number":161,"context_line":"the Kafka driver be used. The configuration options can be modified"},{"line_number":162,"context_line":"in the ``oslo_messaging_kafka`` section of the service configuration file."},{"line_number":163,"context_line":""},{"line_number":164,"context_line":"Consumer Options"},{"line_number":165,"context_line":"^^^^^^^^^^^^^^^^"},{"line_number":166,"context_line":""},{"line_number":167,"context_line":"kafka_max_fetch_bytes"}],"source_content_type":"text/x-rst","patch_set":5,"id":"9fdfeff1_e11cd26b","line":164,"range":{"start_line":164,"start_character":0,"end_line":164,"end_character":8},"in_reply_to":"bfdaf3ff_c7ce3d2c","updated":"2019-01-23 13:27:27.000000000","message":"Done","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":8770,"name":"Ken Giusti","email":"kgiusti@gmail.com","username":"kgiusti"},"change_message_id":"abc41193dd3ef3f9e5bc89d6d67a9f8e2a8b8f8d","unresolved":false,"context_lines":[{"line_number":165,"context_line":"^^^^^^^^^^^^^^^^"},{"line_number":166,"context_line":""},{"line_number":167,"context_line":"kafka_max_fetch_bytes"},{"line_number":168,"context_line":"    Initial maximum number of byters per topic+partition to request"},{"line_number":169,"context_line":"    when fetching messages from the broker."},{"line_number":170,"context_line":""},{"line_number":171,"context_line":"kafka_consumer_timeout"}],"source_content_type":"text/x-rst","patch_set":5,"id":"bfdaf3ff_a7d9b9f3","line":168,"range":{"start_line":168,"start_character":30,"end_line":168,"end_character":36},"updated":"2019-01-17 19:22:55.000000000","message":"ouch","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"9d52202c64255825218b69d7ba62d130987bc3b5","unresolved":false,"context_lines":[{"line_number":165,"context_line":"^^^^^^^^^^^^^^^^"},{"line_number":166,"context_line":""},{"line_number":167,"context_line":"kafka_max_fetch_bytes"},{"line_number":168,"context_line":"    Initial maximum number of byters per topic+partition to request"},{"line_number":169,"context_line":"    when fetching messages from the broker."},{"line_number":170,"context_line":""},{"line_number":171,"context_line":"kafka_consumer_timeout"}],"source_content_type":"text/x-rst","patch_set":5,"id":"9fdfeff1_0118f672","line":168,"range":{"start_line":168,"start_character":30,"end_line":168,"end_character":36},"in_reply_to":"bfdaf3ff_a7d9b9f3","updated":"2019-01-23 13:27:27.000000000","message":"Done","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":8770,"name":"Ken Giusti","email":"kgiusti@gmail.com","username":"kgiusti"},"change_message_id":"abc41193dd3ef3f9e5bc89d6d67a9f8e2a8b8f8d","unresolved":false,"context_lines":[{"line_number":178,"context_line":"    Indicator to perform asynchrounous consumer message commits."},{"line_number":179,"context_line":""},{"line_number":180,"context_line":"max_poll_records"},{"line_number":181,"context_line":"    The maximum number of messages to terurn per consume/poll operation."},{"line_number":182,"context_line":""},{"line_number":183,"context_line":"Producer Options"},{"line_number":184,"context_line":"^^^^^^^^^^^^^^^^"}],"source_content_type":"text/x-rst","patch_set":5,"id":"bfdaf3ff_27f70962","line":181,"range":{"start_line":181,"start_character":38,"end_line":181,"end_character":44},"updated":"2019-01-17 19:22:55.000000000","message":"cofefe?","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"9d52202c64255825218b69d7ba62d130987bc3b5","unresolved":false,"context_lines":[{"line_number":178,"context_line":"    Indicator to perform asynchrounous consumer message commits."},{"line_number":179,"context_line":""},{"line_number":180,"context_line":"max_poll_records"},{"line_number":181,"context_line":"    The maximum number of messages to terurn per consume/poll operation."},{"line_number":182,"context_line":""},{"line_number":183,"context_line":"Producer Options"},{"line_number":184,"context_line":"^^^^^^^^^^^^^^^^"}],"source_content_type":"text/x-rst","patch_set":5,"id":"9fdfeff1_612222a7","line":181,"range":{"start_line":181,"start_character":38,"end_line":181,"end_character":44},"in_reply_to":"bfdaf3ff_27f70962","updated":"2019-01-23 13:27:27.000000000","message":"Done","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":8770,"name":"Ken Giusti","email":"kgiusti@gmail.com","username":"kgiusti"},"change_message_id":"abc41193dd3ef3f9e5bc89d6d67a9f8e2a8b8f8d","unresolved":false,"context_lines":[{"line_number":180,"context_line":"max_poll_records"},{"line_number":181,"context_line":"    The maximum number of messages to terurn per consume/poll operation."},{"line_number":182,"context_line":""},{"line_number":183,"context_line":"Producer Options"},{"line_number":184,"context_line":"^^^^^^^^^^^^^^^^"},{"line_number":185,"context_line":""},{"line_number":186,"context_line":"producer_batch_timeout"}],"source_content_type":"text/x-rst","patch_set":5,"id":"bfdaf3ff_e7d341d4","line":183,"updated":"2019-01-17 19:22:55.000000000","message":"\"Notifier Options\"?","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"9d52202c64255825218b69d7ba62d130987bc3b5","unresolved":false,"context_lines":[{"line_number":180,"context_line":"max_poll_records"},{"line_number":181,"context_line":"    The maximum number of messages to terurn per consume/poll operation."},{"line_number":182,"context_line":""},{"line_number":183,"context_line":"Producer Options"},{"line_number":184,"context_line":"^^^^^^^^^^^^^^^^"},{"line_number":185,"context_line":""},{"line_number":186,"context_line":"producer_batch_timeout"}],"source_content_type":"text/x-rst","patch_set":5,"id":"9fdfeff1_213c1ac7","line":183,"in_reply_to":"bfdaf3ff_e7d341d4","updated":"2019-01-23 13:27:27.000000000","message":"Done","commit_id":"cfac2c711f9d0138c98ca1d933721543bbb3edca"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"56004a4c06d3451e47c84d9b1160fb8b31a36192","unresolved":false,"context_lines":[{"line_number":101,"context_line":"Prerequisites"},{"line_number":102,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":103,"context_line":""},{"line_number":104,"context_line":"In order to run the driver the confluent-kafka python client must be"},{"line_number":105,"context_line":"installed. The Kafka driver integrates a `Python client based on librdkafka`_"},{"line_number":106,"context_line":"for full protocol support and utilizes the Producer API to publish"},{"line_number":107,"context_line":"notification messages and the Consumer API for notification listener"}],"source_content_type":"text/x-rst","patch_set":6,"id":"9fdfeff1_8f84b15f","line":104,"range":{"start_line":104,"start_character":31,"end_line":104,"end_character":46},"updated":"2019-02-13 10:07:35.000000000","message":"``literal``","commit_id":"0953fa17593af1cda67760e32b49f14e7405dd85"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"56004a4c06d3451e47c84d9b1160fb8b31a36192","unresolved":false,"context_lines":[{"line_number":109,"context_line":""},{"line_number":110,"context_line":".. _Python client based on librdkafka: https://github.com/confluentinc/confluent-kafka-python"},{"line_number":111,"context_line":""},{"line_number":112,"context_line":"Source packages for the `confluent-kafka library`_ are available via PyPI."},{"line_number":113,"context_line":"Since the Kafka driver is an optional extension to *oslo.messaging*"},{"line_number":114,"context_line":"these packages are not installed by default.  Use the \u0027kafka\u0027 extras"},{"line_number":115,"context_line":"tag when installing *oslo.messaging* in order to pull in these extra"}],"source_content_type":"text/x-rst","patch_set":6,"id":"9fdfeff1_6f7f0d66","line":112,"range":{"start_line":112,"start_character":24,"end_line":112,"end_character":50},"updated":"2019-02-13 10:07:35.000000000","message":"``literal`` (double backticks)","commit_id":"0953fa17593af1cda67760e32b49f14e7405dd85"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"56004a4c06d3451e47c84d9b1160fb8b31a36192","unresolved":false,"context_lines":[{"line_number":129,"context_line":"Transport URL Enable"},{"line_number":130,"context_line":"--------------------"},{"line_number":131,"context_line":""},{"line_number":132,"context_line":"In *oslo.messaging*, the transport_url parameters define the OpenStack service"},{"line_number":133,"context_line":"backends for RPC and Notify. The url is of the form::"},{"line_number":134,"context_line":""},{"line_number":135,"context_line":"    transport://user:pass@host1:port[,hostN:portN]/virtual_host"}],"source_content_type":"text/x-rst","patch_set":6,"id":"9fdfeff1_2f958587","line":132,"range":{"start_line":132,"start_character":25,"end_line":132,"end_character":38},"updated":"2019-02-13 10:07:35.000000000","message":"``literal``. Alternatively, could we use the \u0027:oslo.config:option\u0027 role?","commit_id":"0953fa17593af1cda67760e32b49f14e7405dd85"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"56004a4c06d3451e47c84d9b1160fb8b31a36192","unresolved":false,"context_lines":[{"line_number":155,"context_line":"in the ``oslo_messaging_kafka`` section of the service configuration file."},{"line_number":156,"context_line":""},{"line_number":157,"context_line":"Notification Listener Options"},{"line_number":158,"context_line":"^^^^^^^^^^^^^^^^^^^^^^^^^^^^^"},{"line_number":159,"context_line":""},{"line_number":160,"context_line":"kafka_max_fetch_bytes"},{"line_number":161,"context_line":"    Initial maximum number of bytes per topic+partition to request"}],"source_content_type":"text/x-rst","patch_set":6,"id":"9fdfeff1_afee551f","line":158,"range":{"start_line":158,"start_character":0,"end_line":158,"end_character":29},"updated":"2019-02-13 10:07:35.000000000","message":"Could we use \u0027~~~\u0027 (unles \u0027^^^\u0027 is used for H3 elsewhere in these docs, in which case I need to go fix that)\n\nLater: I see the heading in this entire doc are rather odd. Can fix that later","commit_id":"0953fa17593af1cda67760e32b49f14e7405dd85"},{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"56004a4c06d3451e47c84d9b1160fb8b31a36192","unresolved":false,"context_lines":[{"line_number":157,"context_line":"Notification Listener Options"},{"line_number":158,"context_line":"^^^^^^^^^^^^^^^^^^^^^^^^^^^^^"},{"line_number":159,"context_line":""},{"line_number":160,"context_line":"kafka_max_fetch_bytes"},{"line_number":161,"context_line":"    Initial maximum number of bytes per topic+partition to request"},{"line_number":162,"context_line":"    when fetching messages from the broker."},{"line_number":163,"context_line":""}],"source_content_type":"text/x-rst","patch_set":6,"id":"9fdfeff1_2fda6577","line":160,"range":{"start_line":160,"start_character":0,"end_line":160,"end_character":21},"updated":"2019-02-13 10:07:35.000000000","message":"Could probably have used the \u0027:oslo.config:option:\u0027 role here too","commit_id":"0953fa17593af1cda67760e32b49f14e7405dd85"}],"oslo_messaging/_drivers/impl_kafka.py":[{"author":{"_account_id":15334,"name":"Stephen Finucane","display_name":"stephenfin","email":"stephenfin@redhat.com","username":"sfinucan"},"change_message_id":"56004a4c06d3451e47c84d9b1160fb8b31a36192","unresolved":false,"context_lines":[{"line_number":378,"context_line":"class KafkaDriver(base.BaseDriver):"},{"line_number":379,"context_line":"    \"\"\"Kafka Driver"},{"line_number":380,"context_line":""},{"line_number":381,"context_line":"    See :doc:`kafka` for details."},{"line_number":382,"context_line":"    \"\"\""},{"line_number":383,"context_line":""},{"line_number":384,"context_line":"    def __init__(self, conf, url, default_exchange\u003dNone,"}],"source_content_type":"text/x-python","patch_set":6,"id":"9fdfeff1_8f0591c4","line":381,"range":{"start_line":381,"start_character":8,"end_line":381,"end_character":20},"updated":"2019-02-13 10:07:35.000000000","message":"I think this should be \u0027/admin/kafka\u0027, otherwise we\u0027re assuming the API documentation for this lives in the \u0027/admin\u0027 folder (which may be true but it\u0027s a bit of an assumption and very likely to break)","commit_id":"0953fa17593af1cda67760e32b49f14e7405dd85"}]}