Re: Kafka Topic Permissions Failure

.flink.connector.base.source.reader.fetcher.SplitFetcher >> .run(SplitFetcher.java:105) >> at java.base/java.util.concurrent.Executors$RunnableAdapter.call( >> Executors.java:515) >> at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) >> at

Kafka Topic Permissions Failure

sk.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker( ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run( ThreadPoolExecutor.java:628) ... 1 more Caused by: org.apache.kafka.common.errors.TopicAuthorizationException: -- RAZIN

Admin Client Configs

Looking for some guidance on overriding Kafka admin client configs. The partition discovery feature sometimes fails to connect with kafka and we'd like to implement retries. There is no clear documentation on which settings need to be changed?admin client configs of note: - default.api.timeout.

CVE-2019-14887

lt;https://github.com/apache/flink/blob/54679fd7ddba64e1edfecb5928d025e08a74def8/flink-filesystems/flink-s3-fs-presto/src/main/resources/META-INF/NOTICE#L57> There is a fix for this CVE in Widlfly v1.0.10.Final. Can we create a Jira and/or assist with upgrading to 1.0.10? Thank you, Razin -- RAZI

Re: Flink versions release 1.14.3

ttps://protect2.fireeye.com/v1/url?k=31323334-501d5122-313273af-45444731-fd31185de25f09c0&q=1&e=2db295fd-56aa-4bf5-b85b-af3d3208c625&u=https%3A%2F%2Flists.apache.org%2Fthread%2F24v8bh3jww7c5bvfgov9cp5mb0wtj7tk> >> >> >> >> On Fri, 7 Jan 2022 at 07:30, Deepti Sharm