Package | Description |
---|---|
org.axonframework.kafka.eventhandling.consumer |
Modifier and Type | Class and Description |
---|---|
class |
SortedKafkaMessageBuffer<E extends Comparable & KafkaMetadataProvider>
Thread safe buffer for storing incoming Kafka messages in sorted order defined via
Comparable . |
Modifier and Type | Class and Description |
---|---|
class |
KafkaEventMessage |
Copyright © 2010–2018. All rights reserved.