• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

Parsely / pykafka / 1415
38%

Build:
DEFAULT BRANCH: master
Ran 28 Feb 2018 03:27PM UTC
Jobs 1
Files 44
Run time 9s
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst

pending completion
1415

Pull #477

travis-ci

Yung-Chin Oei
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 #477: ssl support

62 of 980 relevant lines covered (6.33%)

0.13 hits per line

Jobs
ID Job ID Ran Files Coverage
5 1415.5 (KAFKA_VERSION=0.8.2.2) 28 Feb 2018 03:27PM UTC 0
6.33
Travis Job 1415.5
Source Files on build 1415
Detailed source file information is not available for this build.
  • Back to Repo
  • Travis Build #1415
  • Pull Request #477
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2026 Coveralls, Inc