Class CloudKafkaRestContext

java.lang.Object

io.confluent.kafkarest.auth.CloudKafkaRestContext

All Implemented Interfaces:

io.confluent.kafkarest.KafkaRestContext

public class CloudKafkaRestContext
extends Object
implements io.confluent.kafkarest.KafkaRestContext

Constructor Summary

Constructors

Constructor	Description
CloudKafkaRestContext(CloudPrincipal principal, io.confluent.kafkarest.KafkaRestConfig config, RestRequestProxyProtocolInfo proxyProtocolInfo)

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.clients.admin.Admin	getAdmin()
Properties	getAdminProperties()
io.confluent.kafkarest.KafkaRestConfig	getConfig()
org.apache.kafka.clients.consumer.Consumer<byte[],byte[]>	getConsumer(Properties properties)
Properties	getConsumerProperties()
io.confluent.kafkarest.v2.KafkaConsumerManager	getKafkaConsumerManager()
org.apache.kafka.clients.producer.Producer<byte[],byte[]>	getProducer()
String	getProducerCacheKey()
Map<String,Object>	getProducerConfigs()
void	shutdown()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.confluent.kafkarest.KafkaRestContext

getSchemaRegistryClient

Constructor Details

CloudKafkaRestContext

public CloudKafkaRestContext(CloudPrincipal principal,
 io.confluent.kafkarest.KafkaRestConfig config,
 RestRequestProxyProtocolInfo proxyProtocolInfo)

Method Details

getConfig

public io.confluent.kafkarest.KafkaRestConfig getConfig()

Specified by:

getConfig in interface io.confluent.kafkarest.KafkaRestContext

getKafkaConsumerManager

public io.confluent.kafkarest.v2.KafkaConsumerManager getKafkaConsumerManager()

Specified by:

getKafkaConsumerManager in interface io.confluent.kafkarest.KafkaRestContext

getAdmin

public org.apache.kafka.clients.admin.Admin getAdmin()

Specified by:

getAdmin in interface io.confluent.kafkarest.KafkaRestContext

getAdminProperties

public Properties getAdminProperties()

getProducerConfigs

public Map<String,Object> getProducerConfigs()

getConsumerProperties

public Properties getConsumerProperties()

getProducerCacheKey

public String getProducerCacheKey()

getProducer

public org.apache.kafka.clients.producer.Producer<byte[],byte[]> getProducer()

Specified by:

getProducer in interface io.confluent.kafkarest.KafkaRestContext

getConsumer

public org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> getConsumer(Properties properties)

Specified by:

getConsumer in interface io.confluent.kafkarest.KafkaRestContext

shutdown

public void shutdown()

Specified by:

shutdown in interface io.confluent.kafkarest.KafkaRestContext