GitHub user gavrie opened a pull request:
https://github.com/apache/kafka/pull/4247
KAFKA-6250: Use existing internal topics without requiring ACL
When using Kafka Connect with a cluster that doesn't allow the user to
create topics (due to ACL configuration), Connect fails when trying to
create its internal topics, even if these topics already exist. This is
incorrect behavior according to the documentation, which mentions that
R/W access should be enough.
This happens specifically when using Aiven Kafka, which does not permit
creation of topics via the Kafka Admin Client API.
The patch ignores the returned error, similar to the behavior for older
brokers that don't support the API.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/gavrie/kafka trunk
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/4247.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #4247
----
commit 0b17d56257784d9def1418ab87650cd240892227
Author: Gavrie Philipson <gav...@philipson.co.il>
Date: 2017-11-22T06:56:28Z
KAFKA-6250: Use existing internal topics without requiring ACL
When using Kafka Connect with a cluster that doesn't allow the user to
create topics (due to ACL configuration), Connect fails when trying to
create its internal topics, even if these topics already exist. This is
incorrect behavior according to the documentation, which mentions that
R/W access should be enough.
This happens specifically when using Aiven Kafka, which does not permit
creation of topics via the Kafka Admin Client API.
The patch ignores the returned error, similar to the behavior for older
brokers that don't support the API.
----
---
