Samza Test

2020-12-19 Thread Stuart Perks 
I have a Samza application that writes into a table back by a changelog. 

Is there any way to assert on the data stored in the table using Samza test 
using the InMemorySystemDescriptor after data has been run into the topology? 

Thanks

Re: SAMZA-2612: Kafka topic naming not supported fully

2020-12-19 Thread Stuart Perks 
This can be done using withPhysicalName

Closed the JIRA

On 2020/12/17 12:19:27, Stuart Perks  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 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 pageViewStreamDescriptor = 
> kafkaSystemDescriptor.getInputDescriptor("page.view.topic", new 
> JsonSerdeV2<>(PageView.class));> 
> Stream Descriptor Validation 
> >
>  
> Kafka Topic Validation 
> >
>