[Kafka Apache Connector] About the connection string

Adilson Ivan da Costa Júnior

Question

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?

06 Feb 2019

freek

Did you fixed the problem I would also like to know what the connection string should be?

23 Jan 2020

freek

The extension is wrong and cant be used without tweaking it.

30 Jan 2020

1 reply

07 Sep 2022

Show thread

Hide thread

Ahsan Qadeer

can you please describe more, how to tweak the connector

07 Sep 2022

Meetali Gupta

Were you able to find what information we need to provide in Connection string? If yes, please let me know.

07 Nov 2022

Community GuidelinesBe kind and respectful, give credit to the original source of content, and search for duplicates before posting.