[Kafka Apache Connector] About the connection string

Forge Component
(0)
Published on 2018-11-29 by Diogo Pires
0 votes
Published on 2018-11-29 by Diogo Pires

Hey guys!


I have some questions about the connection string.

Usually in a Python Application you do the configuration like this: 

 conf = {

        'bootstrap.servers': os.environ['CLOUDKARAFKA_BROKERS'],

        'session.timeout.ms': 6000,

        'default.topic.config': {'auto.offset.reset': 'smallest'},

        'security.protocol': 'SASL_SSL',

'sasl.mechanisms': 'SCRAM-SHA-256',

        'sasl.username': os.environ['CLOUDKARAFKA_USERNAME'],

        'sasl.password': os.environ['CLOUDKARAFKA_PASSWORD']

    }


But in the extension I only have the Broker, GroupName, Topic and ConnectionString.


How do I mount the ConnectionString based on that?


I guess it's something like: 

server.cloudkafka.com:9094?username:user&password:password&security:SASL_SSL


Can you please help me on this matter?