Skip to content

Allow to config Sasl configs in Kafka sink.#11422

Merged
BewareMyPower merged 2 commits intoapache:masterfrom
hezhangjian:master
Jul 27, 2021
Merged

Allow to config Sasl configs in Kafka sink.#11422
BewareMyPower merged 2 commits intoapache:masterfrom
hezhangjian:master

Conversation

@hezhangjian
Copy link
Member

Motivation

Allow pulsar io to push messages to sasl kafka cluster.

Modifications

Add several kafka sasl configs, make them configable.

Documentation

I think the pulsar-io can automatically generate the doc for added fields. So we don't need add any docs.

@Anonymitaet Anonymitaet added the doc-not-needed Your PR changes do not impact docs label Jul 22, 2021
Copy link
Contributor

@BewareMyPower BewareMyPower left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Please add tests for these configs. You can modify the existed kafkaSinkConfig.yaml under resource directory.

@eolivelli
Copy link
Contributor

for the tests simple unit tests around KafkaAbstractSink#open() is enough.
We do not need integration tests (they will be very heavyweight)

Copy link
Contributor

@eolivelli eolivelli left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The patch overall looks good to me
please add the tests as @BewareMyPower commented

Copy link
Contributor

@eolivelli eolivelli left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@BewareMyPower BewareMyPower merged commit 3afbef2 into apache:master Jul 27, 2021
codelipenghui pushed a commit that referenced this pull request Dec 15, 2021
related to #11422

### Motivation
Allow pulsar io to consume messages to sasl kafka cluster.

### Modifications

Add several kafka sasl configs, make them configable.
fxbing pushed a commit to fxbing/pulsar that referenced this pull request Dec 19, 2021
related to apache#11422

### Motivation
Allow pulsar io to consume messages to sasl kafka cluster.

### Modifications

Add several kafka sasl configs, make them configable.
bharanic-dev pushed a commit to bharanic-dev/pulsar that referenced this pull request Mar 18, 2022
### Motivation
Allow pulsar io to push messages to sasl kafka cluster.

### Modifications

Add several kafka sasl configs, make them configable.


### Documentation
I think the pulsar-io can automatically generate the doc for added fields. So we don't need add any docs.
@momo-jun momo-jun added doc-complete Your PR changes impact docs and the related docs have been already added. and removed doc-not-needed Your PR changes do not impact docs labels Oct 11, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

area/connector doc-complete Your PR changes impact docs and the related docs have been already added.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

6 participants