Browse Source

Merge pull request #8020 from dcamper/kafka_14683

HPCC-14683 Make Kafka SetMessageOffsets() work correctly in multi-node setup

Reviewed-by: Gavin Halliday <ghalliday@hpccsystems.com>
Gavin Halliday 9 năm trước cách đây
mục cha
commit
ccab572663
1 tập tin đã thay đổi với 1 bổ sung1 xóa
  1. 1 1
      plugins/kafka/kafka.ecllib

+ 1 - 1
plugins/kafka/kafka.ecllib

@@ -214,7 +214,7 @@ EXPORT Consumer(VARSTRING topic, VARSTRING brokers = 'localhost', VARSTRING cons
         // Set the offset for each partition on each node
         result := PROJECT
             (
-                distOffsets,
+                NOFOLD(distOffsets),
                 TRANSFORM
                     (
                         ResultLayout,