Uses of Class
org.mockserver.async.security.KafkaSecurity
Packages that use KafkaSecurity
Package
Description
-
Uses of KafkaSecurity in org.mockserver.async.publish
Constructors in org.mockserver.async.publish with parameters of type KafkaSecurityModifierConstructorDescriptionKafkaAvroMessagePublisher(String bootstrapServers, KafkaSecurity security, String schemaJson, SchemaRegistryClient registryClient, int fixedSchemaId) KafkaMessagePublisher(String bootstrapServers, KafkaSecurity security) Create a publisher connected to the given Kafka bootstrap servers with optional security configuration. -
Uses of KafkaSecurity in org.mockserver.async.security
Methods in org.mockserver.async.security that return KafkaSecurityModifier and TypeMethodDescriptionKafkaSecurity.Builder.build()static KafkaSecurityKafkaSecurity.empty()Returns a new empty (no-op) security instance.Methods in org.mockserver.async.security with parameters of type KafkaSecurityModifier and TypeMethodDescriptionstatic voidKafkaSecurityProperties.applySecurity(Properties props, KafkaSecurity security) Apply security settings to the given Kafka client properties. -
Uses of KafkaSecurity in org.mockserver.async.subscribe
Constructors in org.mockserver.async.subscribe with parameters of type KafkaSecurityModifierConstructorDescriptionKafkaAvroMessageSubscriber(String bootstrapServers, String groupId, int maxRecordedMessages, KafkaSecurity security, SchemaRegistryClient registryClient, String inlineSchemaJson) KafkaAvroMessageSubscriber(String bootstrapServers, String groupId, int maxRecordedMessages, KafkaSecurity security, SchemaRegistryClient registryClient, String inlineSchemaJson, int expectedSchemaId) KafkaMessageSubscriber(String bootstrapServers, String groupId, int maxRecordedMessages, KafkaSecurity security) Create a subscriber with optional security configuration.