[
https://issues.apache.org/jira/browse/FLINK-21059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17269063#comment-17269063
]
Thomas Weise commented on FLINK-21059:
--------------------------------------
{code:java}
Caused by: java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node
assignment.
at
org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
~[kafka-clients-2.4.1.jar:?]
at
org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
~[kafka-clients-2.4.1.jar:?]
at
org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
~[kafka-clients-2.4.1.jar:?]
at
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)
~[kafka-clients-2.4.1.jar:?]
at
org.apache.flink.connector.kafka.source.enumerator.subscriber.TopicListSubscriber.getPartitionChanges(TopicListSubscriber.java:57)
~[flink-connector-kafka_2.12-1.13-20210119.215918-55.jar:1.13-SNAPSHOT]
at
org.apache.flink.connector.kafka.source.enumerator.KafkaSourceEnumerator.discoverAndInitializePartitionSplit(KafkaSourceEnumerator.java:196)
~[flink-connector-kafka_2.12-1.13-20210119.215918-55.jar:1.13-SNAPSHOT]
{code}
> KafkaSourceEnumerator does not honor consumer properties
> --------------------------------------------------------
>
> Key: FLINK-21059
> URL: https://issues.apache.org/jira/browse/FLINK-21059
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.13.0
> Reporter: Thomas Weise
> Assignee: Thomas Weise
> Priority: Major
>
> Enumerator fails when SSL is required because the user provided properties
> are not used to construct the admin client.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
