[GitHub] [incubator-hudi] amitsingh-10 commented on issue #1335: [SUPPORT] HoodieDeltaStreamer Kafka offset reset config not being read

2020-02-16 Thread GitBox
amitsingh-10 commented on issue #1335: [SUPPORT] HoodieDeltaStreamer Kafka offset reset config not being read URL: https://github.com/apache/incubator-hudi/issues/1335#issuecomment-586835214 Closing this issue since I could not find so far anything wrong from Hoodie's end. Thanks for all t

[GitHub] [incubator-hudi] amitsingh-10 commented on issue #1335: [SUPPORT] HoodieDeltaStreamer Kafka offset reset config not being read

2020-02-15 Thread GitBox
amitsingh-10 commented on issue #1335: [SUPPORT] HoodieDeltaStreamer Kafka offset reset config not being read URL: https://github.com/apache/incubator-hudi/issues/1335#issuecomment-586588934 Okay, so I put in some log debugs in the `KafkaOffsetGen#getNextOffsetRanges` function. What I foun

[GitHub] [incubator-hudi] amitsingh-10 commented on issue #1335: [SUPPORT] HoodieDeltaStreamer Kafka offset reset config not being read

2020-02-15 Thread GitBox
amitsingh-10 commented on issue #1335: [SUPPORT] HoodieDeltaStreamer Kafka offset reset config not being read URL: https://github.com/apache/incubator-hudi/issues/1335#issuecomment-586573685 Those offsets are not available in the topic. So, I had set the parameter `auto.offset.reset=earlie

[GitHub] [incubator-hudi] amitsingh-10 commented on issue #1335: [SUPPORT] HoodieDeltaStreamer Kafka offset reset config not being read

2020-02-14 Thread GitBox
amitsingh-10 commented on issue #1335: [SUPPORT] HoodieDeltaStreamer Kafka offset reset config not being read URL: https://github.com/apache/incubator-hudi/issues/1335#issuecomment-586408479 Didn't help. I had already tried, but I tried it again with the `0.5.1-incubating` version. However

[GitHub] [incubator-hudi] amitsingh-10 commented on issue #1335: [SUPPORT] HoodieDeltaStreamer Kafka offset reset config not being read

2020-02-14 Thread GitBox
amitsingh-10 commented on issue #1335: [SUPPORT] HoodieDeltaStreamer Kafka offset reset config not being read URL: https://github.com/apache/incubator-hudi/issues/1335#issuecomment-586330008 The Kafka version is `2.1.0-cp2`. Also is there any PR/issue where I can better understand why fixK

[GitHub] [incubator-hudi] amitsingh-10 commented on issue #1335: [SUPPORT] HoodieDeltaStreamer Kafka offset reset config not being read

2020-02-14 Thread GitBox
amitsingh-10 commented on issue #1335: [SUPPORT] HoodieDeltaStreamer Kafka offset reset config not being read URL: https://github.com/apache/incubator-hudi/issues/1335#issuecomment-586213714 Thanks for the reply @lamber-ken. I tried working with `0.5.0-incubating` however I am getting the