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
KafkaFuture<Map<TopicPartition,DescribeProducersResult.PartitionProducerState>>	all()
KafkaFuture<DescribeProducersResult.PartitionProducerState>	partitionResult(TopicPartition partition)

Methods inherited from class java.lang.Object

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

Method Details

partitionResult

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

all

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