public interface IKafkaConfigurationTask
extends java.rmi.Remote
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
addKafkaConfiguration(KafkaConfigTO dto) |
void |
deleteKafkaConfiguration(java.lang.String keyID) |
KafkaConfigTO |
findKafkaConfigurationByKeyID(java.lang.String keyID) |
java.lang.Object |
findKafkaProducerNonReservedSettings() |
KafkaConfigTO[] |
listAllKafkaConfiguration() |
void |
updateKafkaConfiguration(KafkaConfigTO dto) |
java.lang.Object findKafkaProducerNonReservedSettings()
throws java.rmi.RemoteException
java.rmi.RemoteExceptionvoid updateKafkaConfiguration(KafkaConfigTO dto) throws java.rmi.RemoteException
java.rmi.RemoteExceptionKafkaConfigTO findKafkaConfigurationByKeyID(java.lang.String keyID) throws java.rmi.RemoteException
java.rmi.RemoteExceptionKafkaConfigTO[] listAllKafkaConfiguration() throws java.rmi.RemoteException
java.rmi.RemoteExceptionjava.lang.String addKafkaConfiguration(KafkaConfigTO dto) throws java.rmi.RemoteException
java.rmi.RemoteExceptionvoid deleteKafkaConfiguration(java.lang.String keyID)
throws java.rmi.RemoteException
java.rmi.RemoteException