Hisham Mardam-Bey
Hisham Mardam-Bey
I'm still in the process of reviewing the code, specifically commit b1e019c0e9e393cb1100c5ce44391f2f7503e1dc (NIO changes). The main question I have for you @HeartSaVioR and for the rest of the reviewers and...
@bbnsumanth is there a specific revision that this started with? Can you give more information and an example? Cheers (=
Can you provide a way to reproduce the bug?
@bbnsumanth any movement here? Can you reproduce? If you need help, let me know. Do you still need an answer for the above?
Is this stock MySQL? Also, reckon you can try turning up log levels and see if that helps reveal any additional information? Also, can you push anything into Kafka or...
@jb-san @kubum with #33 and #36 worked on (2cd84a9bf00b780f59ba2a82df065d144e6fdf04) logging should be better, let me know what if this helps.
@kubum the main difference here is MariaDB. I haven't tried mypipe against it recently, and I think it did not work properly last time I tried it. I'll have to...
@rhamnett take a look at: https://github.com/mardambey/mypipe/blob/bb7acf47f9e80b8792b4ed517fa16d82763bd3c9/mypipe-kafka/src/main/scala/mypipe/kafka/consumer/GenericConsoleConsumer.scala The Kafka messages do not just consist of the Avro data. They actually have a specific format which is documented [here](https://github.com/mardambey/mypipe#kafka-message-format). You can use...
@rhamnett Are you trying to do this totally on your own or making use of `KafkaGenericMutationAvroConsumer`? If you do not use `KafkaGenericMutationAvroConsumer`, you have to decode the bytes yourself based...
@rhamnett cheers - I'll take a look at this as soon as I can.