Interface KafkaClientOperations
-
- All Known Implementing Classes:
BasicExternalKafkaClient,InternalKafkaClient,OauthExternalKafkaClient,TracingExternalKafkaClient
public interface KafkaClientOperationsInterface KafkaClientOperations used for basic operations with the clients
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description intreceiveMessagesPlain(long timeoutMs)Receiving plain messages with the selected clientintreceiveMessagesTls(long timeoutMs)Sending encrypted messages using Tls technology with the selected clientintsendMessagesPlain(long timeoutMs)Sending plain messages with the selected clientintsendMessagesTls(long timeoutMs)Sending encrypted messages using Tls technology with the selected client
-
-
-
Method Detail
-
sendMessagesPlain
int sendMessagesPlain(long timeoutMs) throws ExceptionSending plain messages with the selected client- Parameters:
timeoutMs- timeout in milliseconds- Returns:
- count of messages
- Throws:
Exception- exception
-
sendMessagesTls
int sendMessagesTls(long timeoutMs) throws ExceptionSending encrypted messages using Tls technology with the selected client- Parameters:
timeoutMs- timeout in milliseconds- Returns:
- count of messages
- Throws:
Exception- exception
-
receiveMessagesPlain
int receiveMessagesPlain(long timeoutMs) throws ExceptionReceiving plain messages with the selected client- Parameters:
timeoutMs- timeout in milliseconds- Returns:
- count of messages
- Throws:
Exception- exception
-
-