[
https://issues.apache.org/jira/browse/KAFKA-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16098554#comment-16098554
]
Bart Vercammen commented on KAFKA-5386:
---------------------------------------
[~mjsax] Thanks for the reply. The `through("...")` would already help me a
little bit, thanks for the tip.
With respect to the changelog topics, will this be included in upcoming
versions of KafkaStreams?
It actually does make sense to be able to define the topic names myself,
especially with Kafka ACLs in play.
It would be nice to be able to configure the changelog topic _prefix_ and
_suffix_ somehow.
I have a local fork where I implemented this, it's a bit dirty and purely as a
proof of concept, but would it make sense to rework this into a valid PR?
> [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.4.14#64029)
