actors/org.artofdev.actors.impl.net.kafka/KafkaActorNet

KafkaActorNet

class KafkaActorNet(topicPrefix: String, jacksonMapper: ObjectMapper, kafkaProducer: KafkaProducerInterface, kafkaConsumerConfig: KafkaConsumerConfig, kafkaConsumerFactory: ConsumerForActorFactory) : IActorNet

Constructors

Link copied to clipboard
constructor(topicPrefix: String, jacksonMapper: ObjectMapper, kafkaProducer: KafkaProducerInterface, kafkaConsumerConfig: KafkaConsumerConfig, kafkaConsumerFactory: ConsumerForActorFactory)

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
open override fun connectActor(address: ActorIdent, group: ActorGroup?, subscriptions: List<ActorIdent>): ActorConnection
Link copied to clipboard
open override fun createActorGroup(address: ActorIdent): ActorGroup
Link copied to clipboard
open override fun deliverMessage(message: MessageEnvelope)
Generated by Dokka
© 2026 Copyright