io.simplesource.kafka.api

Interface ResourceNamingStrategy

All Known Implementing Classes:

PrefixResourceNamingStrategy

public interface ResourceNamingStrategy

Method Summary

Modifier and Type	Method and Description
String	topicName(String aggregateName, String topicEntity) Generate the Kafka topic name to use for a given aggregate domain.

Method Detail

topicName

String topicName(String aggregateName,
                 String topicEntity)

Generate the Kafka topic name to use for a given aggregate domain.

Parameters:

aggregateName - name of the domain aggregate

topicEntity - entities stored in this topic

Returns:

name of the Kafka topic to use