Hey, Stuart, Sounds great that you have found the way around it! Thanks!
-Yi On Sat, Dec 19, 2020 at 12:28 PM Stuart Perks <stuart.m.pe...@gmail.com> wrote: > This can be done using withPhysicalName > > Closed the JIRA > > On 2020/12/17 12:19:27, Stuart Perks <s...@gmail.com> wrote: > > https://issues.apache.org/jira/browse/SAMZA-2612> > > > > Raised a bug JIRA but wanted to check with the community. Any thoughts > would be great.> > > > > > > The StreamDescriptor class cannot accept all acceptable formats for > Kafka Topic names.> > > StreamDescriptor> > > private static final Pattern STREAM_ID_PATTERN = > Pattern.compile("[\\d\\w-_]+");> > > Kafka Topic Validation> > > public static final String LEGAL_CHARS = "[a-zA-Z0-9._-]";> > > Taking the example this is valid> > > KafkaInputDescriptor<PageView> pageViewStreamDescriptor = > kafkaSystemDescriptor.getInputDescriptor("page-view-topic", new > JsonSerdeV2<>(PageView.class));> > > but this is not if we use the name page.view.topic as . Is not valid in > the StreamDescriptor.> > > KafkaInputDescriptor<PageView> pageViewStreamDescriptor = > kafkaSystemDescriptor.getInputDescriptor("page.view.topic", new > JsonSerdeV2<>(PageView.class));> > > Stream Descriptor Validation < > https://github.com/apache/samza/blob/master/samza-api/src/main/java/org/apache/samza/system/descriptors/StreamDescriptor.java#L48>> > > > Kafka Topic Validation < > https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/internals/Topic.java#L29>> >
