кафка коннект трансформации - PullRequest
0 голосов
/ 03 октября 2018

Я хочу передать данные из postgreSQL в HDFS, но во всех моих таблицах есть несколько столбцов отметок времени.Я пробовал простое соединение jdbc и приемник HDFS, предлагаемые конфлуентом, для чтения данных из postgres и записи их в HDFS, но все мои столбцы с датами конвертируются в BigInt вместо формата даты.Я не знаю, в каком формате находится этот большой int, но его нет в метке времени Unix. Есть ли какие-либо причины, чтобы узнать, в каком формате это?Я также думаю преобразовать столбцы даты в метку времени UNIX в моем соединении jdbc, а затем преобразовать их в дату в моем приемнике, используя TimeStampConverter .Но я не знаю, как реализовать это в моей текущей процедуре.О проблеме сообщается здесь .

...