You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by GitBox <gi...@apache.org> on 2021/06/24 14:59:48 UTC

[GitHub] [hudi] veenaypatil edited a comment on pull request #3136: [HUDI-2060] Added tests for KafkaOffsetGen

veenaypatil edited a comment on pull request #3136:
URL: https://github.com/apache/hudi/pull/3136#issuecomment-867543880


   @vinothchandar  added tests for multiple partitions
   
   > adding a new partition between two fetches and seeing that the new partition is picked up
   
   not able to add new partition, tried using 
   ```
   Map<Object, Seq<Object>> newPartitionsAssignment =
               adminZkClient.addPartitions(TEST_TOPIC_NAME,partitionAssignment,
                       JavaConversions.asScalaBuffer(brokerMetadataList), 3, 
                       scala.Option.apply(JavaConversions.mapAsScalaMap(replicaAssignment)), 
                       false);
   ```
   which is not working


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org