Index
All Classes and Interfaces|All Packages|Serialized Form
A
- adminClient - Variable in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
- assertCountInTopicMethod(String, int, int) - Method in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
- awaitMs - Variable in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
-
default ms await in tests
B
- bootStrapServer - Variable in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
C
- consumer() - Method in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
- consumerTimeoutMs - Variable in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
-
default max ms for consumer
- createTopic(String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaInt
-
Creates a topic with one partition.
- createTopic(String) - Method in class net.bugreaper.modules.kafka.Kafka
- createTopic(String, int) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaInt
-
Creates a topic with multiple partitions.
- createTopic(String, int) - Method in class net.bugreaper.modules.kafka.Kafka
- createTopicMethod(String, int) - Method in class net.bugreaper.modules.kafka.setup.KafkaAdminHelper
D
- deleteTopic(String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaInt
-
Deletes a topic.
- deleteTopic(String) - Method in class net.bugreaper.modules.kafka.Kafka
- deleteTopicMethod(String) - Method in class net.bugreaper.modules.kafka.setup.KafkaAdminHelper
G
- getAllTopicsNames() - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaInt
-
Returns a list of all topic names.
- getAllTopicsNames() - Method in class net.bugreaper.modules.kafka.Kafka
- getAllTopicsNamesMethod() - Method in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
- getConfigSummary() - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaConfig
-
Returns and logs (at INFO level) a human-readable summary of all resolved configuration values.
- getConfigSummary() - Method in class net.bugreaper.modules.kafka.Kafka
- getInstance() - Static method in class net.bugreaper.modules.kafka.Kafka
- getMessagesCountInTopic(String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaInt
-
Returns the number of messages in a topic.
- getMessagesCountInTopic(String) - Method in class net.bugreaper.modules.kafka.Kafka
- getPartitionsCount(String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaInt
-
Returns the number of partitions in a topic.
- getPartitionsCount(String) - Method in class net.bugreaper.modules.kafka.Kafka
- getPartitionsCountMethod(String) - Method in class net.bugreaper.modules.kafka.setup.KafkaAdminHelper
- getTopicExistenceMethod(String) - Method in class net.bugreaper.modules.kafka.setup.KafkaAdminHelper
- getTopicMessageCountMethod(String) - Method in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
- grabMessagesFromTopic(String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaInt
-
Grabs messages from a topic using a consumer without committing offsets.
- grabMessagesFromTopic(String) - Method in class net.bugreaper.modules.kafka.Kafka
- grabMessagesFromTopic(String, String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaInt
-
Grabs messages from a topic using a consumer without committing offsets.
- grabMessagesFromTopic(String, String) - Method in class net.bugreaper.modules.kafka.Kafka
- grabMessagesFromTopicMethod(String, String) - Method in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
K
- Kafka - Class in net.bugreaper.modules.kafka
-
Kafka helper that provides a common API for operating with Kafka.
- Kafka() - Constructor for class net.bugreaper.modules.kafka.Kafka
-
Constructs a MongoDb client using YAML configuration.
- Kafka(String) - Constructor for class net.bugreaper.modules.kafka.Kafka
-
Creates a Kafka helper with the specified bootstrap server.
- KafkaAdminHelper - Class in net.bugreaper.modules.kafka.setup
-
Kafka admin helper that provides a common API for Kafka administration operations.
- KafkaAdminHelper(String) - Constructor for class net.bugreaper.modules.kafka.setup.KafkaAdminHelper
- KafkaAsserts - Interface in net.bugreaper.modules.kafka.interfaces
-
Interface describes methods responsible for helper assertions.
- KafkaConfig - Interface in net.bugreaper.modules.kafka.interfaces
-
Interface that defines helper configuration methods for helper operations.
- KafkaConsumerHelper - Class in net.bugreaper.modules.kafka.setup
-
Kafka consumer helper responsible for consuming messages from Kafka topics.
- KafkaConsumerHelper(String) - Constructor for class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
- KafkaHelperException - Exception in net.bugreaper.modules.kafka.exceptions
-
Exception for Kafka helper
- KafkaHelperException(String) - Constructor for exception net.bugreaper.modules.kafka.exceptions.KafkaHelperException
-
Basic exception for Kafka helper
- KafkaHelperException(String, Throwable) - Constructor for exception net.bugreaper.modules.kafka.exceptions.KafkaHelperException
-
Basic exception for Kafka helper
- KafkaHelperException(Throwable) - Constructor for exception net.bugreaper.modules.kafka.exceptions.KafkaHelperException
-
Basic exception for Kafka helper
- KafkaInt - Interface in net.bugreaper.modules.kafka.interfaces
-
Interface defines methods for facilitating helper interactions.
- KafkaProducerHelper - Class in net.bugreaper.modules.kafka.setup
-
Kafka producer helper responsible for sending messages to Kafka topics.
- KafkaProducerHelper(String) - Constructor for class net.bugreaper.modules.kafka.setup.KafkaProducerHelper
L
- Log - Class in net.bugreaper.modules.kafka.logger
-
Utility class for handling logging within the Kafka module.
- LOGGER - Static variable in class net.bugreaper.modules.kafka.logger.Log
-
Logger instance for the Kafka module.
M
- maxConsumedMessages - Variable in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
-
default max messages that will be consumed by grab
N
- net.bugreaper.modules.kafka - package net.bugreaper.modules.kafka
- net.bugreaper.modules.kafka.exceptions - package net.bugreaper.modules.kafka.exceptions
- net.bugreaper.modules.kafka.interfaces - package net.bugreaper.modules.kafka.interfaces
- net.bugreaper.modules.kafka.logger - package net.bugreaper.modules.kafka.logger
- net.bugreaper.modules.kafka.setup - package net.bugreaper.modules.kafka.setup
P
- purgeTopic(String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaInt
-
Purges a topic by removing messages from all partitions.
- purgeTopic(String) - Method in class net.bugreaper.modules.kafka.Kafka
- purgeTopicMethod(String) - Method in class net.bugreaper.modules.kafka.setup.KafkaAdminHelper
R
- reverseMessages - Variable in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
-
default consumed messages will be reversed in list (newer messages will be checked first)
S
- seeMessagesContainJson(String, String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaAsserts
-
Asserts that at least one of messages in topic contains the specified JSON without strict array ordering.
- seeMessagesContainJson(String, String) - Method in class net.bugreaper.modules.kafka.Kafka
- seeMessagesContainText(String, String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaAsserts
-
Asserts that at least one of messages in topic contains the specified text.
- seeMessagesContainText(String, String) - Method in class net.bugreaper.modules.kafka.Kafka
- seeMessagesCountInTopicExactly(String, int) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaAsserts
-
Asserts that the number of messages in the topic is exactly the expected count.
- seeMessagesCountInTopicExactly(String, int) - Method in class net.bugreaper.modules.kafka.Kafka
- seeMessagesHaveEqualJson(String, String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaAsserts
-
Asserts that at least one of messages in topic is equal to the specified JSON with strict array ordering.
- seeMessagesHaveEqualJson(String, String) - Method in class net.bugreaper.modules.kafka.Kafka
- seeMessagesHaveEqualText(String, String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaAsserts
-
Asserts that at least one message in the topic is equal to the expected text.
- seeMessagesHaveEqualText(String, String) - Method in class net.bugreaper.modules.kafka.Kafka
- seeTopicExists(String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaAsserts
-
Asserts that the topic exists.
- seeTopicExists(String) - Method in class net.bugreaper.modules.kafka.Kafka
- seeTopicExistsMethod(String, int) - Method in class net.bugreaper.modules.kafka.setup.KafkaAdminHelper
- seeTopicIsEmpty(String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaAsserts
-
Asserts that the topic is empty.
- seeTopicIsEmpty(String) - Method in class net.bugreaper.modules.kafka.Kafka
- seeTopicIsEmptyMethod(String, int) - Method in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
- seeTopicIsNotEmpty(String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaAsserts
-
Asserts that the topic is not empty
- seeTopicIsNotEmpty(String) - Method in class net.bugreaper.modules.kafka.Kafka
- seeTopicIsNotEmptyMethod(String, int) - Method in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
- send(String, String) - Method in class net.bugreaper.modules.kafka.setup.KafkaProducerHelper
- sending(String, ProducerRecord<String, String>) - Method in class net.bugreaper.modules.kafka.setup.KafkaProducerHelper
- sendToTopic(String, String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaInt
-
Sends a message to a topic.
- sendToTopic(String, String) - Method in class net.bugreaper.modules.kafka.Kafka
- sendToTopicWithKey(String, String, String) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaInt
-
Sends a message with a key to a topic.
- sendToTopicWithKey(String, String, String) - Method in class net.bugreaper.modules.kafka.Kafka
- sendWithKey(String, String, String) - Method in class net.bugreaper.modules.kafka.setup.KafkaProducerHelper
- setAwaitMs(int) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaConfig
-
Configures the global await timeout for assertions and operations that use await.
- setAwaitMs(int) - Method in class net.bugreaper.modules.kafka.Kafka
- setConsumerTimeoutMs(int) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaConfig
-
Sets the consumer timeout.
- setConsumerTimeoutMs(int) - Method in class net.bugreaper.modules.kafka.Kafka
- setMaxConsumeMessages(int) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaConfig
-
Sets the maximum number of latest messages to consume.
- setMaxConsumeMessages(int) - Method in class net.bugreaper.modules.kafka.Kafka
- setReverseMessages(boolean) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaConfig
-
Sets the message ordering behavior.
- setReverseMessages(boolean) - Method in class net.bugreaper.modules.kafka.Kafka
- setUniqueConsumer(boolean) - Method in interface net.bugreaper.modules.kafka.interfaces.KafkaConfig
-
Enables or disables generating a unique consumer group ID.
- setUniqueConsumer(boolean) - Method in class net.bugreaper.modules.kafka.Kafka
U
- uniqueConsumerGroup - Variable in class net.bugreaper.modules.kafka.setup.KafkaConsumerHelper
-
switch for unique groupId for consumer
All Classes and Interfaces|All Packages|Serialized Form