[
https://issues.apache.org/jira/browse/FLINK-27824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544034#comment-17544034
]
Zixuan Rao commented on FLINK-27824:
------------------------------------
Yep. Although I’m on a tight schedule recently. I might not be able to fully
get to this until late July. I managed to temporarily work around this issue by
calling Kafka in the MapFunction (with no delivery guarantee whatsoever).
> Implement Pyflink KeyedSchema
> -----------------------------
>
> Key: FLINK-27824
> URL: https://issues.apache.org/jira/browse/FLINK-27824
> Project: Flink
> Issue Type: Improvement
> Components: API / Python
> Reporter: Zixuan Rao
> Priority: Minor
> Original Estimate: 20h
> Remaining Estimate: 20h
>
> This issue is to implement KeyedSchema for pyflink. Currently, only keyless
> schema is supported. This prevents me from emitting keyed kafka entries to
> datastream kafka connector. I plan to implement this on my own.
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
