Hi,
Gentle nudge on this. Would appreciate some initial thoughts/feedback.
Best,
Levani
> On 28. Nov 2024, at 12:04, Levani Kokhreidze wrote:
>
> Hello dear Flink community,
>
>
> I made a small improvement in Flink’s Kafka Source and would appreciate
> communities
Hello dear Flink community,
I made a small improvement in Flink’s Kafka Source and would appreciate
communities feedback on it if it makes sense.
Idea is to let users of the KafkaSource pass their own KafkaConsumerFactory
that controls the creation of KafkaConsumer instances.
JIRA: https://iss
Levani Kokhreidze created FLINK-36817:
-
Summary: Give users ability to provide their own KafkaConsumer
when using flink-connector-kafka
Key: FLINK-36817
URL: https://issues.apache.org/jira/browse/FLINK-36817
Levani Kokhreidze created FLINK-28473:
-
Summary: JobManager restart/failover doesn't trigger local
recovery on TaskManagers
Key: FLINK-28473
URL: https://issues.apache.org/jira/browse/FLINK-
Levani Kokhreidze created FLINK-20982:
-
Summary: Flink TaskManager throws RegistrationTimeoutException
when using Kubernetes HA
Key: FLINK-20982
URL: https://issues.apache.org/jira/browse/FLINK-20982