Re: [DISCUSS] FLINK-36817 Feedback

2024-12-04 Thread Levani Kokhreidze
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

[DISCUSS] FLINK-36817 Feedback

2024-11-28 Thread Levani Kokhreidze
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

[jira] [Created] (FLINK-36817) Give users ability to provide their own KafkaConsumer when using flink-connector-kafka

2024-11-28 Thread Levani Kokhreidze (Jira)
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

[jira] [Created] (FLINK-28473) JobManager restart/failover doesn't trigger local recovery on TaskManagers

2022-07-09 Thread Levani Kokhreidze (Jira)
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-

[jira] [Created] (FLINK-20982) Flink TaskManager throws RegistrationTimeoutException when using Kubernetes HA

2021-01-14 Thread Levani Kokhreidze (Jira)
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