Levani Kokhreidze

icon company @transferwise icon location Earth, Solar System icon location Focusing on stream processing platforms. Java, Kafka, Kafka Streams, Flink, K8s.

Results 2 issues of Levani Kokhreidze

Checkpointing to s3 using minio doesn't work

Hello @alpinegizmo I've tried to use your example to have checkpointing in s3 using minio. I'm using docker compose setup and what I've noticed that checkpointing doesn't really and I...

[FLINK-36817] Introduce KafkaConsumerFactory

2 comment

In certain scenarios users of the `KafkaSource` in the flink-connector-kafka might want to provide their own KafkaConsumer. Right now this is not possible as consumer is created in the [KafkaPartitionSplitReader](https://github.com/apache/flink-connector-kafka/blob/main/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java#L97)...

component=Connectors/Kafka