Feasibility check to add deserializer while consuming records from Kafka

debuggerrr / RankedMatchmaking

This repo will be used to create groups of players with the same rank hierarchy to have fair fights.

0 stars 0 forks source link

Feasibility check to add deserializer while consuming records from Kafka #8

Closed debuggerrr closed 1 year ago

debuggerrr commented 1 year ago

Check the implementation of the Deserializer class for converting the normal string elements to tuples of string

debuggerrr commented 1 year ago

As per research, Kafka messages are converted into POJO class in Java but custom deserialization doesn't seem to be possible in Pyflink as of now therefore closing this issue for now.