public void setShardAssigner ( KinesisShardAssigner shardAssigner ) { this . shardAssigner = checkNotNull ( shardAssigner , "function can not be null" ) ; ClosureCleaner . clean ( shardAssigner , true ) ; }
Provide a custom assigner to influence how shards are distributed over subtasks .