Hello guys,

We are trying out nifi in one of our usecases to get mysql changes and dump
to hadoop in Booking.com . We are using CaptureChangeMysql processor to
read binlogs and process it in later stages. So far everything works fine,
but when the column is of unsigned primitive type, its not able to read the
data properly when the value overflows. I investigated a bit and came
across this (
https://github.com/shyiko/mysql-binlog-connector-java/issues/104). The
library which is internally being used in CaptureChangeMysql Processor (
https://github.com/shyiko/mysql-binlog-connector-java) does not handle this
case and its upto consumer to handle it. More description can be found in
the link.

Before writing any kind of patch, I wanted to check Since this is quite
common case, has anyone come across this? It would be really great if
someone can suggest a solution on this.

Nifi version  : 1.6.0
Mysql version : 5.7.22-log
Binlog type.  : Row-based logging

Thanks a lot

Ashwin Konale
Developer

Booking.com B.V.
Herengracht 597 Amsterdam 1017 CE Netherlands
Direct +31207242562
[image: Booking.com] <https://www.booking.com/>
The world's #1 accommodation site
43 languages, 198+ offices worldwide, 120,000+ global destinations,
1,550,000+ room nights booked every day
No booking fees, best price always guaranteed
Subsidiary of Booking Holdings Inc. (NASDAQ: BKNG)

Reply via email to