5
38%
master: 38%

Ran 28 Feb 2018 03:27PM UTC

Files 44

Run time 2s

Badge

Embed ▾

Committed 28 Feb 2018 03:27PM UTC coverage: 6.327%. First build

Job # KAFKA_VERSION=0.8.2.2

Build Type

Pull #477

travis-ci

Committed by Yung-Chin Oei

Commit Message

client: enable ssl option [WIP]

This is the simplest change that works (except for the rdkafka module,
which still needs updating).  For connecting with the testinstances
cluster (which was configured for TLS in the parent commit), you can do:

    import pykafka, ssl, functools
    ssl_context = ssl.create_default_context(
        cafile="/tmp/kafka-bin/test-certs/root.cert")
    ssl_context.load_cert_chain(
        certfile="/tmp/kafka-bin/test-certs/client.cert",
        keyfile="/tmp/kafka-bin/test-certs/client.key",
        password=b"dWJTxlilbJcH1Wgn")
    wrap = functools.partial(
        ssl_context.wrap_socket,
        server_hostname="localhost")
    client = pykafka.KafkaClient(
        "localhost:9093",
        ssl_wrap_socket=wrap)

However we probably still need to change the interface a bit: we'll need
to store cafile, certfile, keyfile and password, because in the current
format there's no way to obtain these and pass them into the rdkafka
config.

Signed-off-by: Yung-Chin Oei <yungchin@yungchin.nl>

Pull Request Pull Request #477: ssl support

Run Details

62 of 980 relevant lines covered (6.33%)

0.06 hits per line

Parsely / pykafka / 1415 / 5
38%
master: 38%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Source Files on job 1415.5 (KAFKA_VERSION=0.8.2.2)

Parsely / pykafka / 1415 / 5 38% master: 38%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Source Files on job 1415.5 (KAFKA_VERSION=0.8.2.2)

Parsely / pykafka / 1415 / 5
38%
master: 38%

README BADGES
x