#Java - Code Snippets for '#Storm.kafka.PartitionManager'

Search Java Code Snippets

Help us in improving the repository. Add new snippets through 'Submit Code Snippet ' link.

Submit Code Snippet

#Java - Code Snippets for '#Storm.kafka.PartitionManager' - 1 code snippet(s) found

Sample 1. Code Sample / Example / Snippet of org.apache.storm.kafka.PartitionManager.KafkaMessageId

    public void ack(Object msgId) {

        KafkaMessageId id = (KafkaMessageId) msgId;

        PartitionManager m = _coordinator.getManager(id.partition);

        if (m != null) {

            m.ack(id.offset);

        }

    }

_{Like Feedback org.apache.storm.kafka.PartitionManager.KafkaMessageId}