public abstract class AbstractProducer<M extends Message> extends Object implements ProducerIterator<M>
Constructor and Description |
---|
AbstractProducer(int producerId) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
int |
getProducerId() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getPartition, remove
forEachRemaining, hasNext, next
public AbstractProducer(int producerId)
public int getProducerId()
public void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2017 Nuxeo. All rights reserved.