mypipe
mypipe copied to clipboard
mardambey
MySQL binary log consumer with the ability to act on changed rows and publish changes to different systems with emphasis on Apache Kafka.
In order to product ordered message, can we set the hashcode of primary key to message key? How to do that?
Found that,some times values from one table are zipped with metadata of other tables.I'm trying to figure out this .In case if you can suggest me some possible places to...
Hello, wondered if you could kindly help. I'm trying to retrieve a generic insert mutation message from a kafka queue which was posted to the queue using the kafka-generic mypipe.producer.KafkaMutationGenericAvroProducer...
 this time is very slow, why
Hi, I am new to Kafka and have a requirement to read binary log of MySQL and publish it to Kafka. I have followed your "readme" file and have mdoified...
can you tell me how to run mypipe, my english is low I can not to run mypipe "project runner" "runMain mypipe.runner.KafkaGenericConsoleConsumer $world_$test_generic 127.0.0.1:4180 groupId" project runner need to use...
1、don't get mysql binary log file position, some error output info like this: 19:29:57 INFO [m.a.r.ConfigurableFileBasedBinaryLogPositionRepository] Saving binlog position for pipe mysql-bin-position/10.0.46.116-3306 -> null:4 19:29:57 INFO [m.a.r.ConfigurableMySQLBasedBinaryLogPositionRepository] Saving binlog position...
I've a MySql table with a primary key of type Int (unsigned), when the id is bigger than the max Int value the id becomes a negative value, as expected....
I have mysql setup with binlog and format = row my application.conf: ``` mypipe { # consumers represent sources for mysql binary logs consumers { database1 { # database "host:port:user:pass"...
