[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

Posted on 6 Feb

Posted on 6 Feb

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?

Dislike(0)

Like(0)

Dislike(0)

Like(0)

Available Forums