Package io.quarkus.kafka.client.runtime.dev.ui

Class KafkaJsonRPCService

java.lang.Object

io.quarkus.kafka.client.runtime.dev.ui.KafkaJsonRPCService

public class KafkaJsonRPCService
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
(package private) io.quarkus.kafka.client.runtime.KafkaAdminClient	kafkaAdminClient
(package private) KafkaUiUtils	kafkaUiUtils

Constructor Summary

Constructors

Constructor	Description
KafkaJsonRPCService()

Method Summary

Modifier and Type	Method	Description
KafkaMessagePage	createMessage(String topicName, Integer partition, String key, String value, Map<String,String> headers)
List<KafkaTopic>	createTopic(String topicName, int partitions, int replications, Map<String,String> configs)
List<KafkaTopic>	deleteTopic(String topicName)
KafkaAclInfo	getAclInfo()
KafkaInfo	getInfo()
List<Integer>	getPartitions(String topicName)
List<KafkaTopic>	getTopics()
io.smallrye.mutiny.Multi<String>	stateNotification()
KafkaMessagePage	topicMessages(String topicName)

Methods inherited from class java.lang.Object

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

Field Details

kafkaUiUtils

@Inject
KafkaUiUtils kafkaUiUtils

kafkaAdminClient

@Inject
io.quarkus.kafka.client.runtime.KafkaAdminClient kafkaAdminClient

Constructor Details

KafkaJsonRPCService

public KafkaJsonRPCService()

Method Details

stateNotification

public io.smallrye.mutiny.Multi<String> stateNotification()

getTopics

@JsonRpcDescription("Get all the current Kafka topics")
@DevMCPEnableByDefault
public List<KafkaTopic> getTopics()
                           throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

createTopic

@JsonRpcDescription("Create a new Kafka topic")
@DevMCPEnableByDefault
public List<KafkaTopic> createTopic(@JsonRpcDescription("The Kafka topic name")
 String topicName,
 @JsonRpcDescription("The number of partitions, example 1")
 int partitions,
 @JsonRpcDescription("The number of replications, example 1")
 int replications,
 @JsonRpcDescription("Other config in map format (key/value)")
 Map<String,String> configs)
                             throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

deleteTopic

@JsonRpcDescription("Delete an existing Kafka topic")
@DevMCPEnableByDefault
public List<KafkaTopic> deleteTopic(@JsonRpcDescription("The Kafka topic name")
 String topicName)
                             throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

topicMessages

@JsonRpcDescription("Get all the current messages for a certain Kafka topics")
@DevMCPEnableByDefault
public KafkaMessagePage topicMessages(@JsonRpcDescription("The Kafka topic name")
 String topicName)
                               throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

createMessage

@JsonRpcDescription("Create a new message on a specific Kafka topic")
@DevMCPEnableByDefault
public KafkaMessagePage createMessage(@JsonRpcDescription("The Kafka topic name")
 String topicName,
 @JsonRpcDescription("The partition number, example 1")
 Integer partition,
 @JsonRpcDescription("The message key")
 String key,
 @JsonRpcDescription("The message value")
 String value,
 @JsonRpcDescription("The message headers in map format (key/value)")
 Map<String,String> headers)
                               throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

getPartitions

@JsonRpcDescription("Get the partitions for a specific Kafka topic")
public List<Integer> getPartitions(@JsonRpcDescription("The Kafka topic name")
 String topicName)
                            throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

getInfo

@JsonRpcDescription("Get all know information on the Kafka instance")
@DevMCPEnableByDefault
public KafkaInfo getInfo()
                  throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

getAclInfo

@JsonRpcDescription("Get all know information about the use access control lists for authorization in Kafka")
public KafkaAclInfo getAclInfo()
                        throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException