Interface KafkaClientOperations
-
- All Known Implementing Classes:
BasicExternalKafkaClient
,InternalKafkaClient
,OauthExternalKafkaClient
,TracingExternalKafkaClient
public interface KafkaClientOperations
Interface KafkaClientOperations used for basic operations with the clients
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description int
receiveMessagesPlain(long timeoutMs)
Receiving plain messages with the selected clientint
receiveMessagesTls(long timeoutMs)
Sending encrypted messages using Tls technology with the selected clientint
sendMessagesPlain(long timeoutMs)
Sending plain messages with the selected clientint
sendMessagesTls(long timeoutMs)
Sending encrypted messages using Tls technology with the selected client
-
-
-
Method Detail
-
sendMessagesPlain
int sendMessagesPlain(long timeoutMs) throws Exception
Sending plain messages with the selected client- Parameters:
timeoutMs
- timeout in milliseconds- Returns:
- count of messages
- Throws:
Exception
- exception
-
sendMessagesTls
int sendMessagesTls(long timeoutMs) throws Exception
Sending 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 Exception
Receiving plain messages with the selected client- Parameters:
timeoutMs
- timeout in milliseconds- Returns:
- count of messages
- Throws:
Exception
- exception
-
-