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>
