Package org.apache.kafka.clients.admin

Class DescribeProducersResult

java.lang.Object

org.apache.kafka.clients.admin.DescribeProducersResult

@Evolving
public class DescribeProducersResult
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DescribeProducersResult.PartitionProducerState

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.common.KafkaFuture<Map<org.apache.kafka.common.TopicPartition,DescribeProducersResult.PartitionProducerState>>	all()
org.apache.kafka.common.KafkaFuture<DescribeProducersResult.PartitionProducerState>	partitionResult(org.apache.kafka.common.TopicPartition partition)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

partitionResult

public org.apache.kafka.common.KafkaFuture<DescribeProducersResult.PartitionProducerState> partitionResult(org.apache.kafka.common.TopicPartition partition)

all

public org.apache.kafka.common.KafkaFuture<Map<org.apache.kafka.common.TopicPartition,DescribeProducersResult.PartitionProducerState>> all()