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

Package-level declarations

Types

ActorConnectionKafkaImpl

class ActorConnectionKafkaImpl : ActorConnection

ActorKafkaPropertiesProvider

class ActorKafkaPropertiesProvider(kafkaPropertiesFilename: String)

ConsumerForActorFactory

interface ConsumerForActorFactory

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

KafkaConsumerConfig

data class KafkaConsumerConfig(val noPollingTimeoutSec: Long? = null, val poolTimeoutMs: Long = 10000)

KafkaConsumerInterface

typealias KafkaConsumerInterface = Consumer<String, String>

KafkaConsumerThread

class KafkaConsumerThread : Closeable

KafkaProducerInterface

typealias KafkaProducerInterface = Producer<String, String>

class KafkaSender(jacksonMapper: ObjectMapper, val kafkaProducer: Producer<String, String>) : Closeable

RawConsumerRecord

typealias RawConsumerRecord = ConsumerRecord<String, String>

RawProducerRecord

typealias RawProducerRecord = ProducerRecord<String, String>

StdConsumerForActorFactory

class StdConsumerForActorFactory(val kafkaPropertiesProvider: ActorKafkaPropertiesProvider) : ConsumerForActorFactory

Functions

createKafkaRawProducer

fun createKafkaRawProducer(propertiesFilename: String): KafkaProducerInterface