index
:
delta/openstack/oslo-messaging.git
feature/amqp-dispatch-router
feature/nats-driver
feature/pika
feature/zmq
master
stable/2023.1
stable/icehouse
stable/juno
stable/kilo
stable/liberty
stable/mitaka
stable/newton
stable/ocata
stable/pike
stable/queens
stable/rocky
stable/stein
stable/train
stable/ussuri
stable/victoria
stable/wallaby
stable/xena
stable/yoga
stable/zed
opendev.org: openstack/oslo.messaging.git
summary
refs
log
tree
commit
diff
log msg
author
committer
range
path:
root
/
oslo_messaging
/
_drivers
/
impl_kafka.py
Commit message (
Expand
)
Author
Age
Files
Lines
*
Add support for kafka SSL autentication
Michal Arbet
2020-01-16
1
-1
/
+10
*
Do not use threading.Event
John Eckersberg
2019-12-18
1
-1
/
+1
*
Merge "Support kafka message compression"
10.0.0
Zuul
2019-08-05
1
-0
/
+2
|
\
|
*
Support kafka message compression
zhang-shaoman
2019-06-20
1
-0
/
+2
*
|
Add the "transport_options" parameter to the amqp1 and kafka drivers.
Kenneth Giusti
2019-06-20
1
-1
/
+1
|
/
*
Kafka driver deployment guide
Andy Smith
2019-01-23
1
-1
/
+1
*
Switch driver to confluent-kafka client library
Andy Smith
2018-12-04
1
-107
/
+138
*
Don't use monotonic with Python >=3.3
Andy Smith
2018-12-03
1
-2
/
+2
*
Remove default_{host,port} deprecated options
Steve Kowalik
2018-09-05
1
-8
/
+1
*
[rabbitmq] Implement active call monitoring
Dan Smith
2018-05-09
1
-1
/
+5
*
Merge "Add heartbeat() method to RpcIncomingMessage"
Zuul
2018-05-01
1
-0
/
+3
|
\
|
*
Add heartbeat() method to RpcIncomingMessage
Dan Smith
2018-04-24
1
-0
/
+3
*
|
Add kafka for python 3 functional test
Andrew Smith
2018-04-17
1
-1
/
+1
|
/
*
Add kafka config options for security (ssl/sasl)
Andrew Smith
2018-02-13
1
-14
/
+37
*
Add support for synchronous commit
Andrew Smith
2018-01-18
1
-4
/
+8
*
Add kafka driver vhost emulation
5.35.0
Andrew Smith
2017-12-27
1
-73
/
+86
*
Update kafka functional test
Andrew Smith
2017-12-16
1
-1
/
+2
*
Add kafka_driver directory
Andrew Smith
2017-06-13
1
-1
/
+1
*
drivers: use common.ConfigOptsProxy everywhere
Mehdi Abaakouk
2017-02-27
1
-1
/
+1
*
Fix type of the kafka_consumer_timeout option
Pierre Riteau
2017-02-13
1
-1
/
+1
*
kafka: ensure topics are created
Mehdi Abaakouk
2017-01-26
1
-0
/
+5
*
kafka: fix python3 exception
Mehdi Abaakouk
2017-01-26
1
-1
/
+1
*
kafka: remove no really implemented feature
Mehdi Abaakouk
2017-01-02
1
-24
/
+4
*
kafka: return to poller when timeout is reach
Mehdi Abaakouk
2017-01-02
1
-11
/
+20
*
kafka: Don't hide unpack/unserialize exception
Mehdi Abaakouk
2017-01-02
1
-27
/
+24
*
kafka: timeout is in milliseconds
Mehdi Abaakouk
2017-01-02
1
-1
/
+1
*
kafka: disable batch for functional tests
Mehdi Abaakouk
2017-01-02
1
-7
/
+1
*
kafka: Remove Producer singleton
Mehdi Abaakouk
2017-01-02
1
-53
/
+31
*
Moving driver to new kafka-python version
Ilya Tyaptin
2017-01-02
1
-120
/
+163
*
[kafka] invoke TypeError exception when 'listen()' method of KafkaDriver
Hiroyasu.OHYAMA
2016-08-29
1
-1
/
+1
*
Introduce TTL for idle connections
Kirill Bespalov
2016-07-22
1
-1
/
+12
*
Merge "kafka: Deprecates host, port options"
Jenkins
2016-05-24
1
-0
/
+4
|
\
|
*
kafka: Deprecates host, port options
Mehdi Abaakouk
2016-05-20
1
-0
/
+4
*
|
Merge "Remove logging from serialize_remote_exception"
Jenkins
2016-05-20
1
-1
/
+1
|
\
\
|
|
/
|
/
|
|
*
Remove logging from serialize_remote_exception
Gevorg Davoian
2016-05-19
1
-1
/
+1
*
|
Merge "[kafka] Add several bootstrap servers support"
Jenkins
2016-05-19
1
-14
/
+11
|
\
\
|
|
/
|
/
|
|
*
[kafka] Add several bootstrap servers support
Ildar Svetlov
2016-05-19
1
-14
/
+11
*
|
Refactor base interfaces
Dmitriy Ukhlov
2016-04-20
1
-4
/
+3
|
/
*
Merge "[kafka] Do not remove kafka_client during reset"
Jenkins
2016-04-10
1
-6
/
+3
|
\
|
*
[kafka] Do not remove kafka_client during reset
Ilya Tyaptin
2016-04-05
1
-6
/
+3
*
|
Refactor driver's listener interface
Dmitriy Ukhlov
2016-04-05
1
-3
/
+6
|
/
*
Merge "Use only unique topics for the Kafka driver"
Jenkins
2016-03-21
1
-2
/
+2
|
\
|
*
Use only unique topics for the Kafka driver
Ilya Tyaptin
2016-03-21
1
-2
/
+2
*
|
[Kafka] Ensure a topics before consume messages
Ilya Tyaptin
2016-03-21
1
-0
/
+3
*
|
Merge "Revert "Ensure the json result type is bytes on Python 3""
Jenkins
2016-03-11
1
-1
/
+1
|
\
\
|
*
|
Revert "Ensure the json result type is bytes on Python 3"
Victor Stinner
2016-03-11
1
-1
/
+1
*
|
|
Merge "Ensure the json result type is bytes on Python 3"
Jenkins
2016-03-11
1
-1
/
+1
|
\
\
\
|
|
/
/
|
|
/
|
|
/
|
/
|
|
*
Ensure the json result type is bytes on Python 3
Javeme
2016-02-24
1
-1
/
+1
*
|
[kafka] Use notification priority
Oleksii Zamiatin
2016-02-26
1
-4
/
+6
*
|
Use PortOpt on kafka_default_port
Eric Brown
2016-02-24
1
-2
/
+2
|
/
[next]
