)]}'
{"specs/liberty/adding-kafka-support.rst":[{"author":{"_account_id":4190,"name":"lifeless","email":"robertc@robertcollins.net","username":"lifeless"},"change_message_id":"b6ee457daea5d66152868522733ed08effac9ea2","unresolved":false,"context_lines":[{"line_number":15,"context_line":"to appear the new kafaka related implementation in existing or future OpenStack project."},{"line_number":16,"context_line":"This blueprint aims to implement kafka publisher and subscriber in oslo_messaging to"},{"line_number":17,"context_line":"make log-centric communication support, and can reduce the wasting time for next"},{"line_number":18,"context_line":"developers to reimplemant the same functionality."},{"line_number":19,"context_line":""},{"line_number":20,"context_line":"Proposed change"},{"line_number":21,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"}],"source_content_type":"text/x-rst","patch_set":2,"id":"fa32b979_7edb5c7c","line":18,"updated":"2015-06-19 02:08:20.000000000","message":"typo:reimplement","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":4190,"name":"lifeless","email":"robertc@robertcollins.net","username":"lifeless"},"change_message_id":"b6ee457daea5d66152868522733ed08effac9ea2","unresolved":false,"context_lines":[{"line_number":20,"context_line":"Proposed change"},{"line_number":21,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":22,"context_line":""},{"line_number":23,"context_line":"To reduce the cost of implementing kafka communication functinality independently,"},{"line_number":24,"context_line":"oslo_messaging has to provide the kafka subscriber/publisher supports. Kafka is not"},{"line_number":25,"context_line":"expected to be used as a RPC broker, this means the functions of kafka is not conflict"},{"line_number":26,"context_line":"with existing RPC codes, adding the support like oslo_messaging.kafka_service."}],"source_content_type":"text/x-rst","patch_set":2,"id":"fa32b979_3ee1542a","line":23,"updated":"2015-06-19 02:08:20.000000000","message":"functionality","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":4190,"name":"lifeless","email":"robertc@robertcollins.net","username":"lifeless"},"change_message_id":"b6ee457daea5d66152868522733ed08effac9ea2","unresolved":false,"context_lines":[{"line_number":21,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":22,"context_line":""},{"line_number":23,"context_line":"To reduce the cost of implementing kafka communication functinality independently,"},{"line_number":24,"context_line":"oslo_messaging has to provide the kafka subscriber/publisher supports. Kafka is not"},{"line_number":25,"context_line":"expected to be used as a RPC broker, this means the functions of kafka is not conflict"},{"line_number":26,"context_line":"with existing RPC codes, adding the support like oslo_messaging.kafka_service."},{"line_number":27,"context_line":""}],"source_content_type":"text/x-rst","patch_set":2,"id":"fa32b979_fed52c42","line":24,"updated":"2015-06-19 02:08:20.000000000","message":"support","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":4190,"name":"lifeless","email":"robertc@robertcollins.net","username":"lifeless"},"change_message_id":"b6ee457daea5d66152868522733ed08effac9ea2","unresolved":false,"context_lines":[{"line_number":22,"context_line":""},{"line_number":23,"context_line":"To reduce the cost of implementing kafka communication functinality independently,"},{"line_number":24,"context_line":"oslo_messaging has to provide the kafka subscriber/publisher supports. Kafka is not"},{"line_number":25,"context_line":"expected to be used as a RPC broker, this means the functions of kafka is not conflict"},{"line_number":26,"context_line":"with existing RPC codes, adding the support like oslo_messaging.kafka_service."},{"line_number":27,"context_line":""},{"line_number":28,"context_line":"Alternatives"}],"source_content_type":"text/x-rst","patch_set":2,"id":"fa32b979_1ebd7001","line":25,"updated":"2015-06-19 02:08:20.000000000","message":"will not","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":2813,"name":"Mehdi Abaakouk","email":"sileht@sileht.net","username":"sileht"},"change_message_id":"3db71e22311f64276e30d9b3cf34f797c37b9cfa","unresolved":false,"context_lines":[{"line_number":23,"context_line":"To reduce the cost of implementing kafka communication functinality independently,"},{"line_number":24,"context_line":"oslo_messaging has to provide the kafka subscriber/publisher supports. Kafka is not"},{"line_number":25,"context_line":"expected to be used as a RPC broker, this means the functions of kafka is not conflict"},{"line_number":26,"context_line":"with existing RPC codes, adding the support like oslo_messaging.kafka_service."},{"line_number":27,"context_line":""},{"line_number":28,"context_line":"Alternatives"},{"line_number":29,"context_line":"------------"}],"source_content_type":"text/x-rst","patch_set":2,"id":"3afb71cf_f92e06f9","line":26,"updated":"2015-06-08 14:03:05.000000000","message":"oslo.messaging already have a API to produce notification and to consume them. All openstack componment already use it.\n\nSo, if the plan is to be able to send notification of all openstack to kafka, I still think we should write a oslo.messaging driver and not create a new API. But we don\u0027t need to implements all the drivers interfaces, just the notification is enought.\n\nIf we write new functions just for kafka, that means all openstack applications that use oslo.messaging to send notification have to be changed to use the kafka notifications (this effort looks really big to me).\n\nIn another side, If the current notification abstraction is too bad for kafka, we can improve it too.\n\nAlso oslo.messaging is about backend abstraction of notification and RPC stuffs, so writting an API just for kafka looks doesn\u0027t match the goals.","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":12850,"name":"Komei Shimamura","email":"komei.t.f@gmail.com","username":"kshimamu"},"change_message_id":"46a812011ade91e3ddffa7a706f077ebbf67baa3","unresolved":false,"context_lines":[{"line_number":23,"context_line":"To reduce the cost of implementing kafka communication functinality independently,"},{"line_number":24,"context_line":"oslo_messaging has to provide the kafka subscriber/publisher supports. Kafka is not"},{"line_number":25,"context_line":"expected to be used as a RPC broker, this means the functions of kafka is not conflict"},{"line_number":26,"context_line":"with existing RPC codes, adding the support like oslo_messaging.kafka_service."},{"line_number":27,"context_line":""},{"line_number":28,"context_line":"Alternatives"},{"line_number":29,"context_line":"------------"}],"source_content_type":"text/x-rst","patch_set":2,"id":"fa32b979_404d6698","line":26,"in_reply_to":"3afb71cf_f92e06f9","updated":"2015-06-18 17:39:59.000000000","message":"Thank you for review and sorry for late reply.\nI like your idea. Instead of creating new API, writing Kafka driver for notifications seems to be better, so will change this text. I have one question, did \"we don\u0027t need to implements all the drivers interfaces, just the notification is enought\" mean adding oslo_messaging/_drivers/impl_kafka.py and mainly writing send_notification and other notification related methods in KafkaDriver class? If I have something which I\u0027m not aware of, it\u0027s really helpful for letting me know.\n\nThanks!","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":4190,"name":"lifeless","email":"robertc@robertcollins.net","username":"lifeless"},"change_message_id":"b6ee457daea5d66152868522733ed08effac9ea2","unresolved":false,"context_lines":[{"line_number":23,"context_line":"To reduce the cost of implementing kafka communication functinality independently,"},{"line_number":24,"context_line":"oslo_messaging has to provide the kafka subscriber/publisher supports. Kafka is not"},{"line_number":25,"context_line":"expected to be used as a RPC broker, this means the functions of kafka is not conflict"},{"line_number":26,"context_line":"with existing RPC codes, adding the support like oslo_messaging.kafka_service."},{"line_number":27,"context_line":""},{"line_number":28,"context_line":"Alternatives"},{"line_number":29,"context_line":"------------"}],"source_content_type":"text/x-rst","patch_set":2,"id":"fa32b979_9e3f4086","line":26,"in_reply_to":"fa32b979_404d6698","updated":"2015-06-19 02:08:20.000000000","message":"Yeah, we wouldn\u0027t implement e.g. cast() or call() for kafka.","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":2813,"name":"Mehdi Abaakouk","email":"sileht@sileht.net","username":"sileht"},"change_message_id":"3db71e22311f64276e30d9b3cf34f797c37b9cfa","unresolved":false,"context_lines":[{"line_number":41,"context_line":"Impact on Existing APIs"},{"line_number":42,"context_line":"-----------------------"},{"line_number":43,"context_line":""},{"line_number":44,"context_line":"None"},{"line_number":45,"context_line":""},{"line_number":46,"context_line":"Security impact"},{"line_number":47,"context_line":"---------------"}],"source_content_type":"text/x-rst","patch_set":2,"id":"3afb71cf_b971aeaa","line":44,"updated":"2015-06-08 14:03:05.000000000","message":"https://review.openstack.org/#/c/189006/1 add a new API to olso.messaging and seems can live outside of oslo.messaging.","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":2813,"name":"Mehdi Abaakouk","email":"sileht@sileht.net","username":"sileht"},"change_message_id":"3db71e22311f64276e30d9b3cf34f797c37b9cfa","unresolved":false,"context_lines":[{"line_number":94,"context_line":"----------"},{"line_number":95,"context_line":""},{"line_number":96,"context_line":"Target Milestone for completion:"},{"line_number":97,"context_line":"  Kilo"},{"line_number":98,"context_line":""},{"line_number":99,"context_line":"Work Items"},{"line_number":100,"context_line":"----------"}],"source_content_type":"text/x-rst","patch_set":2,"id":"3afb71cf_1e19c888","line":97,"updated":"2015-06-08 14:03:05.000000000","message":"Should be liberty","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":12850,"name":"Komei Shimamura","email":"komei.t.f@gmail.com","username":"kshimamu"},"change_message_id":"46a812011ade91e3ddffa7a706f077ebbf67baa3","unresolved":false,"context_lines":[{"line_number":94,"context_line":"----------"},{"line_number":95,"context_line":""},{"line_number":96,"context_line":"Target Milestone for completion:"},{"line_number":97,"context_line":"  Kilo"},{"line_number":98,"context_line":""},{"line_number":99,"context_line":"Work Items"},{"line_number":100,"context_line":"----------"}],"source_content_type":"text/x-rst","patch_set":2,"id":"fa32b979_60374aff","line":97,"in_reply_to":"3afb71cf_1e19c888","updated":"2015-06-18 17:39:59.000000000","message":"thanks, will change","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":4190,"name":"lifeless","email":"robertc@robertcollins.net","username":"lifeless"},"change_message_id":"b6ee457daea5d66152868522733ed08effac9ea2","unresolved":false,"context_lines":[{"line_number":111,"context_line":""},{"line_number":112,"context_line":"Ceilometer and Monasca have Kafka use cases. Ceilomter project will get"},{"line_number":113,"context_line":"Kafka publisher as a metrics publisher, and monasca project is using kafka"},{"line_number":114,"context_line":"as a part of their architecture. "},{"line_number":115,"context_line":""},{"line_number":116,"context_line":"Library"},{"line_number":117,"context_line":"-------"}],"source_content_type":"text/x-rst","patch_set":2,"id":"fa32b979_5e4e983b","line":114,"updated":"2015-06-19 02:08:20.000000000","message":"Trailing space.","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":4190,"name":"lifeless","email":"robertc@robertcollins.net","username":"lifeless"},"change_message_id":"b6ee457daea5d66152868522733ed08effac9ea2","unresolved":false,"context_lines":[{"line_number":126,"context_line":"Documentation Impact"},{"line_number":127,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":128,"context_line":""},{"line_number":129,"context_line":"Need to add the chapter which menthions about the logging-centric messaging"},{"line_number":130,"context_line":"supports using Kafka and function explanations witch would be implemented in"},{"line_number":131,"context_line":"oslo_messaging.kafka_service."},{"line_number":132,"context_line":""}],"source_content_type":"text/x-rst","patch_set":2,"id":"fa32b979_1e5490c7","line":129,"updated":"2015-06-19 02:08:20.000000000","message":"mentions","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":4190,"name":"lifeless","email":"robertc@robertcollins.net","username":"lifeless"},"change_message_id":"b6ee457daea5d66152868522733ed08effac9ea2","unresolved":false,"context_lines":[{"line_number":127,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":128,"context_line":""},{"line_number":129,"context_line":"Need to add the chapter which menthions about the logging-centric messaging"},{"line_number":130,"context_line":"supports using Kafka and function explanations witch would be implemented in"},{"line_number":131,"context_line":"oslo_messaging.kafka_service."},{"line_number":132,"context_line":""},{"line_number":133,"context_line":"Dependencies"}],"source_content_type":"text/x-rst","patch_set":2,"id":"fa32b979_3e4f1435","line":130,"updated":"2015-06-19 02:08:20.000000000","message":"support, and which.","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":4190,"name":"lifeless","email":"robertc@robertcollins.net","username":"lifeless"},"change_message_id":"b6ee457daea5d66152868522733ed08effac9ea2","unresolved":false,"context_lines":[{"line_number":128,"context_line":""},{"line_number":129,"context_line":"Need to add the chapter which menthions about the logging-centric messaging"},{"line_number":130,"context_line":"supports using Kafka and function explanations witch would be implemented in"},{"line_number":131,"context_line":"oslo_messaging.kafka_service."},{"line_number":132,"context_line":""},{"line_number":133,"context_line":"Dependencies"},{"line_number":134,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"}],"source_content_type":"text/x-rst","patch_set":2,"id":"fa32b979_be59e4fe","line":131,"updated":"2015-06-19 02:08:20.000000000","message":"I think the python path here is incorrect - wouldn\u0027t it be oslo_messaging._drivers.kafka?","commit_id":"f8500ea96d6a82faf67e0d93f0e03c90031ab0f3"},{"author":{"_account_id":1297,"name":"Joshua Harlow","email":"jxharlow@godaddy.com","username":"harlowja"},"change_message_id":"41d99df1032a41b6eaf6295bc9a930b09b0c1484","unresolved":false,"context_lines":[{"line_number":23,"context_line":"To reduce the cost of implementing kafka communication functionality independently,"},{"line_number":24,"context_line":"it is better to have kafka driver in oslo_messaging. Kafka is not expected to be used as"},{"line_number":25,"context_line":"a RPC broker, this means we do not need to write RPC related methods for kafka."},{"line_number":26,"context_line":""},{"line_number":27,"context_line":"Alternatives"},{"line_number":28,"context_line":"------------"},{"line_number":29,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"fa32b979_b216cca5","line":26,"updated":"2015-06-19 22:17:36.000000000","message":"Isn\u0027t most of oslo.messaging used like an RPC layer (RPC over queues...), wouldn\u0027t that mean u would need RPC related methods, or at least ensure the existing ones still function (therefore making the abstraction that exists work)?","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":1297,"name":"Joshua Harlow","email":"jxharlow@godaddy.com","username":"harlowja"},"change_message_id":"b18ab4929ac73c3d06dfe20b591784fdbfd8498d","unresolved":false,"context_lines":[{"line_number":23,"context_line":"To reduce the cost of implementing kafka communication functionality independently,"},{"line_number":24,"context_line":"it is better to have kafka driver in oslo_messaging. Kafka is not expected to be used as"},{"line_number":25,"context_line":"a RPC broker, this means we do not need to write RPC related methods for kafka."},{"line_number":26,"context_line":""},{"line_number":27,"context_line":"Alternatives"},{"line_number":28,"context_line":"------------"},{"line_number":29,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"fa32b979_64d5bb19","line":26,"in_reply_to":"fa32b979_a92acc2d","updated":"2015-06-27 15:58:55.000000000","message":"Ok dokie,","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":12850,"name":"Komei Shimamura","email":"komei.t.f@gmail.com","username":"kshimamu"},"change_message_id":"20b5d70cbe2a4df23c35d936883752736cbd33bf","unresolved":false,"context_lines":[{"line_number":23,"context_line":"To reduce the cost of implementing kafka communication functionality independently,"},{"line_number":24,"context_line":"it is better to have kafka driver in oslo_messaging. Kafka is not expected to be used as"},{"line_number":25,"context_line":"a RPC broker, this means we do not need to write RPC related methods for kafka."},{"line_number":26,"context_line":""},{"line_number":27,"context_line":"Alternatives"},{"line_number":28,"context_line":"------------"},{"line_number":29,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"ba3cc151_76e27405","line":26,"in_reply_to":"fa32b979_a92acc2d","updated":"2015-06-29 19:28:35.000000000","message":"Thanks for the review. will change this text and reflect your comment.\nDoes \u0027a separate set of plugins\u0027 mean the notification drivers located under oslo_messaging/notify, such as _impl_messaging.py (Messaging driver)?\n\nNotificationDrivers can handle the \u0027notify\u0027 method which is used when notifications are \u0027sent\u0027, but to \u0027receive\u0027 notification data from kafka, probably we needs to add kafka driver into oslo_messaging/_drivers.\n\n(actually we have two kind of drivers in oslo_messaging. one is for only sending notification messages, and the other is send-receive the data for notification and  RPC both. For me personally, if oslo_messaging/notify drivers can have listener, it will be easy to make new notification drivers.)","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":12850,"name":"Komei Shimamura","email":"komei.t.f@gmail.com","username":"kshimamu"},"change_message_id":"881604540d1b1abff58ad4414d602dcecf75b8f2","unresolved":false,"context_lines":[{"line_number":23,"context_line":"To reduce the cost of implementing kafka communication functionality independently,"},{"line_number":24,"context_line":"it is better to have kafka driver in oslo_messaging. Kafka is not expected to be used as"},{"line_number":25,"context_line":"a RPC broker, this means we do not need to write RPC related methods for kafka."},{"line_number":26,"context_line":""},{"line_number":27,"context_line":"Alternatives"},{"line_number":28,"context_line":"------------"},{"line_number":29,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"fa32b979_c5d705ec","line":26,"in_reply_to":"fa32b979_b216cca5","updated":"2015-06-20 03:48:31.000000000","message":"Thanks for the review. yeah, this explanation likely make confusion. What I wanted to write is that the Kafka driver will have \"send\" and \"listen\" methods for RPC abstraction, but will not implement the body of the methods (will raise a NotImplemented exception or something). We will change this description. (Would this be the answer..?)","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":2472,"name":"Doug Hellmann","email":"dhellmann@redhat.com","username":"doug-hellmann"},"change_message_id":"72906d16b9505c7284c902b158490ed821a57035","unresolved":false,"context_lines":[{"line_number":23,"context_line":"To reduce the cost of implementing kafka communication functionality independently,"},{"line_number":24,"context_line":"it is better to have kafka driver in oslo_messaging. Kafka is not expected to be used as"},{"line_number":25,"context_line":"a RPC broker, this means we do not need to write RPC related methods for kafka."},{"line_number":26,"context_line":""},{"line_number":27,"context_line":"Alternatives"},{"line_number":28,"context_line":"------------"},{"line_number":29,"context_line":""}],"source_content_type":"text/x-rst","patch_set":4,"id":"fa32b979_a92acc2d","line":26,"in_reply_to":"fa32b979_c5d705ec","updated":"2015-06-26 21:10:32.000000000","message":"It\u0027s appropriate to think of kafka as useful just for notifications, since that driver is specified separately from the other message bus systems. We do have a separate set of plugins for those drivers already.","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":2472,"name":"Doug Hellmann","email":"dhellmann@redhat.com","username":"doug-hellmann"},"change_message_id":"72906d16b9505c7284c902b158490ed821a57035","unresolved":false,"context_lines":[{"line_number":73,"context_line":"Testing Impact"},{"line_number":74,"context_line":"--------------"},{"line_number":75,"context_line":""},{"line_number":76,"context_line":"None"},{"line_number":77,"context_line":""},{"line_number":78,"context_line":"Implementation"},{"line_number":79,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"}],"source_content_type":"text/x-rst","patch_set":4,"id":"fa32b979_297b1c2b","line":76,"updated":"2015-06-26 21:10:32.000000000","message":"We now have a policy that new messaging drivers need to have integration test jobs that run in the gate. Since kafka is an open source project, we should be able to run it on the OpenStack infrastructure instead of requiring a third-party system, but the work to set up that job will rest on the folks proposing the new driver, and needs to be mentioned here.","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":12850,"name":"Komei Shimamura","email":"komei.t.f@gmail.com","username":"kshimamu"},"change_message_id":"20b5d70cbe2a4df23c35d936883752736cbd33bf","unresolved":false,"context_lines":[{"line_number":73,"context_line":"Testing Impact"},{"line_number":74,"context_line":"--------------"},{"line_number":75,"context_line":""},{"line_number":76,"context_line":"None"},{"line_number":77,"context_line":""},{"line_number":78,"context_line":"Implementation"},{"line_number":79,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"}],"source_content_type":"text/x-rst","patch_set":4,"id":"ba3cc151_2bc80955","line":76,"in_reply_to":"fa32b979_297b1c2b","updated":"2015-06-29 19:28:35.000000000","message":"Will mention about the kafka integration test in OpenStack infrastructure. Thanks for the review!","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":2472,"name":"Doug Hellmann","email":"dhellmann@redhat.com","username":"doug-hellmann"},"change_message_id":"72906d16b9505c7284c902b158490ed821a57035","unresolved":false,"context_lines":[{"line_number":98,"context_line":"Work Items"},{"line_number":99,"context_line":"----------"},{"line_number":100,"context_line":""},{"line_number":101,"context_line":"* Making Kafka driver for oslo_messaging"},{"line_number":102,"context_line":""},{"line_number":103,"context_line":"Incubation"},{"line_number":104,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"}],"source_content_type":"text/x-rst","patch_set":4,"id":"fa32b979_0973b816","line":101,"updated":"2015-06-26 21:10:32.000000000","message":"We usually want a little more detail than that. Some of the things I mention above are good candidates to be included here.","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":12850,"name":"Komei Shimamura","email":"komei.t.f@gmail.com","username":"kshimamu"},"change_message_id":"20b5d70cbe2a4df23c35d936883752736cbd33bf","unresolved":false,"context_lines":[{"line_number":98,"context_line":"Work Items"},{"line_number":99,"context_line":"----------"},{"line_number":100,"context_line":""},{"line_number":101,"context_line":"* Making Kafka driver for oslo_messaging"},{"line_number":102,"context_line":""},{"line_number":103,"context_line":"Incubation"},{"line_number":104,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"}],"source_content_type":"text/x-rst","patch_set":4,"id":"ba3cc151_2bf6c98f","line":101,"in_reply_to":"fa32b979_0973b816","updated":"2015-06-29 19:28:35.000000000","message":"We will add the details for next patch, thanks","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":2472,"name":"Doug Hellmann","email":"dhellmann@redhat.com","username":"doug-hellmann"},"change_message_id":"72906d16b9505c7284c902b158490ed821a57035","unresolved":false,"context_lines":[{"line_number":110,"context_line":""},{"line_number":111,"context_line":"Ceilometer and Monasca have Kafka use cases. Ceilomter project will get"},{"line_number":112,"context_line":"Kafka publisher as a metrics publisher, and monasca project is using kafka"},{"line_number":113,"context_line":"as a part of their architecture."},{"line_number":114,"context_line":""},{"line_number":115,"context_line":"Library"},{"line_number":116,"context_line":"-------"}],"source_content_type":"text/x-rst","patch_set":4,"id":"fa32b979_a9c5ec0a","line":113,"updated":"2015-06-26 21:10:32.000000000","message":"Has the ceilometer team expressed definite interest in the new driver?","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":12850,"name":"Komei Shimamura","email":"komei.t.f@gmail.com","username":"kshimamu"},"change_message_id":"20b5d70cbe2a4df23c35d936883752736cbd33bf","unresolved":false,"context_lines":[{"line_number":110,"context_line":""},{"line_number":111,"context_line":"Ceilometer and Monasca have Kafka use cases. Ceilomter project will get"},{"line_number":112,"context_line":"Kafka publisher as a metrics publisher, and monasca project is using kafka"},{"line_number":113,"context_line":"as a part of their architecture."},{"line_number":114,"context_line":""},{"line_number":115,"context_line":"Library"},{"line_number":116,"context_line":"-------"}],"source_content_type":"text/x-rst","patch_set":4,"id":"ba3cc151_0bb1858f","line":113,"in_reply_to":"fa32b979_a9c5ec0a","updated":"2015-06-29 19:28:35.000000000","message":"For now, Ceilometer has Kafka option to publish the data.\nhttps://github.com/openstack/ceilometer/blob/master/ceilometer/publisher/kafka_broker.py\nWe will change this to more concrete description.","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":2472,"name":"Doug Hellmann","email":"dhellmann@redhat.com","username":"doug-hellmann"},"change_message_id":"72906d16b9505c7284c902b158490ed821a57035","unresolved":false,"context_lines":[{"line_number":126,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":127,"context_line":""},{"line_number":128,"context_line":"Need to add the explanation which mentions about the usage of kafka driver witch"},{"line_number":129,"context_line":"would be mainly implemented in oslo_messaging/_drivers/impl_kafka.py"},{"line_number":130,"context_line":""},{"line_number":131,"context_line":"Dependencies"},{"line_number":132,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"}],"source_content_type":"text/x-rst","patch_set":4,"id":"fa32b979_a9ec0c93","line":129,"updated":"2015-06-26 21:10:32.000000000","message":"We should coordinate with the doc team to figure out where to put that in a guide, but having it in the developer docs for the library for now is a good start.","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":12850,"name":"Komei Shimamura","email":"komei.t.f@gmail.com","username":"kshimamu"},"change_message_id":"20b5d70cbe2a4df23c35d936883752736cbd33bf","unresolved":false,"context_lines":[{"line_number":126,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":127,"context_line":""},{"line_number":128,"context_line":"Need to add the explanation which mentions about the usage of kafka driver witch"},{"line_number":129,"context_line":"would be mainly implemented in oslo_messaging/_drivers/impl_kafka.py"},{"line_number":130,"context_line":""},{"line_number":131,"context_line":"Dependencies"},{"line_number":132,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"}],"source_content_type":"text/x-rst","patch_set":4,"id":"ba3cc151_769ef457","line":129,"in_reply_to":"fa32b979_a9ec0c93","updated":"2015-06-29 19:28:35.000000000","message":"thanks. will change this:)","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":2472,"name":"Doug Hellmann","email":"dhellmann@redhat.com","username":"doug-hellmann"},"change_message_id":"72906d16b9505c7284c902b158490ed821a57035","unresolved":false,"context_lines":[{"line_number":137,"context_line":""},{"line_number":138,"context_line":"Kazoo python package"},{"line_number":139,"context_line":""},{"line_number":140,"context_line":"* https://pypi.python.org/pypi/kazoo"},{"line_number":141,"context_line":""},{"line_number":142,"context_line":"References"},{"line_number":143,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"}],"source_content_type":"text/x-rst","patch_set":4,"id":"fa32b979_2901dc39","line":140,"updated":"2015-06-26 21:10:32.000000000","message":"Can you talk a little about the libraries available to talk to kafka from python, and what support they have for python 3? We have a policy that we are not accepting new requirements that do not work on python 3, so we want to make sure that any issues with that are identified before approving the rest of the work.","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"},{"author":{"_account_id":12850,"name":"Komei Shimamura","email":"komei.t.f@gmail.com","username":"kshimamu"},"change_message_id":"20b5d70cbe2a4df23c35d936883752736cbd33bf","unresolved":false,"context_lines":[{"line_number":137,"context_line":""},{"line_number":138,"context_line":"Kazoo python package"},{"line_number":139,"context_line":""},{"line_number":140,"context_line":"* https://pypi.python.org/pypi/kazoo"},{"line_number":141,"context_line":""},{"line_number":142,"context_line":"References"},{"line_number":143,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"}],"source_content_type":"text/x-rst","patch_set":4,"id":"ba3cc151_36238cbf","line":140,"in_reply_to":"fa32b979_2901dc39","updated":"2015-06-29 19:28:35.000000000","message":"For kafka python package, dealing the communication with kafka brokers, are supporting py3 and actually have already used in Ceilometer.\n\nKazoo is for the communication with Zookeeper, one component to managing kafka clusters and kafka clients, is supporting py3 as well ( https://pypi.python.org/pypi/kazoo | grep \u0027python 3\u0027). \n\nProbably Kazoo package will be removed from the dependencies since this package was planned to be used to synchronize kafka consumers, but during the implementations, we aware that this package might not be needed.","commit_id":"d82be69af0b421d7ccf3036c6beb1eb3f6ab9b5c"}]}