Bart Vercammen created KAFKA-5386:
-------------------------------------
Summary: [Kafka Streams] - custom name for state-store change-log
topic
Key: KAFKA-5386
URL: https://issues.apache.org/jira/browse/KAFKA-5386
Project: Kafka
Issue Type: Improvement
Components: streams
Affects Versions: 0.10.2.1
Reporter: Bart Vercammen
Currently, when working with Kafka backed state stores in Kafka Streams, these
log compacted topics are given a hardcoded name :
_my.app.id-storename-changelog_
{noformat} public static String storeChangelogTopic(String applicationId,
String storeName) {
return applicationId + "-" + storeName + STATE_CHANGELOG_TOPIC_SUFFIX;
}{noformat}
It would be nice if somehow I would be able to override this functionality and
provide the topic-name myself when creating the state-store.
Any comments?
Would it be OK to submit a PR for this?
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)