org.apache.kafka.clients.admin

Class DescribeProducersResult

java.lang.Object

org.apache.kafka.clients.admin.DescribeProducersResult

@InterfaceStability.Evolving
public class DescribeProducersResult
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DescribeProducersResult.PartitionProducerState

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Detail

partitionResult

public KafkaFuture<DescribeProducersResult.PartitionProducerState> partitionResult(TopicPartition partition)

all

public KafkaFuture<Map<TopicPartition,DescribeProducersResult.PartitionProducerState>> all()