Hey Siva,
Can you try adding the following to your table's configuration:
'value.fields-include' = 'EXCEPT_KEY'
Best,
--Gunnar
On Wed, 28 May 2025 at 20:52, Siva Ram Gujju wrote:
> Hello,
>
> I am new to Flink. Running into an issue to read Key from Kafka messages
> in Flink SQL Client.
Hey Praveen,
The PR for upgrading the Flink Kafka connector to Flink 2.0 [1] was merged
a few days ago. Voting for the release of flink-connector-kafka v4.0.0,
release candidate #1 is underway [2], so it shouldn't be too long until
it's out.
--Gunnar
[1] https://github.com/apache/flink-connector
egards
> Lasse Nedergaard
>
>
> Den 26. nov. 2024 kl. 08.13 skrev Gunnar Morling <
> gunnar.morl...@googlemail.com>:
>
>
> Hey all,
>
> Postgres 17 supports failover slots, i.e. a replication slot can be
> created on the primary instance and its state
Hey all,
Postgres 17 supports failover slots, i.e. a replication slot can be created
on the primary instance and its state will be synched to corresponding
slots on a stand-by server.
This allows consumers to continue to read from that slot after promoting a
stand-by to primary, without missing a
Hey,
I ran into some issues with PyFlink on Kubernetes myself a while ago.
Blogged about it here, perhaps it's useful:
https://www.decodable.co/blog/getting-started-with-pyflink-on-kubernetes
Best,
--Gunnar
Am Fr., 14. Juni 2024 um 20:58 Uhr schrieb Mate Czagany :
> Hi,
>
> You can refer t
Hi Ralf,
Have you tried _only_ adding flink-sql-connector-kafka-1.17.1.jar to the
lib directory of your Flink deployment? It is a fat JAR, with all the
dependencies shaded into it, so when you add them separately again, they
will clash.
Best
Am Mi., 11. Okt. 2023 um 04:26 Uhr schrieb Ralph Matth
Hey Ramana,
I can't help you with that particular script, but perhaps this commit
is helpful to you which I did for upgrading the PyFlink Playground
project to 1.16:
https://github.com/apache/flink-playgrounds/commit/4aa9a341bbf49e51809bc9cfcf0e946b2accd8ac
In particular see the changes to
