public interface ProducerIterator<M extends Message> extends Iterator<M>, AutoCloseable
Message
.
It also has the logic to return a shard index, that will be used to run concurrent consumers.Modifier and Type | Method and Description |
---|---|
int |
getShard(M message,
int shards)
Returns a shard index associated with the
Message . |
default void |
remove()
The remove method is not needed.
|
forEachRemaining, hasNext, next
close
default void remove()
Copyright © 2017 Nuxeo. All rights reserved.