Hello, I want my scheduler to listen to a topic regex instead of a particular topic. Is that possible? I don't seem to get it working
vkconfig source --create --cluster my_cluster --source 'mysql-server.inventory.*' --partitions 1 --conf my_config.conf
Outputs
Exception in thread "main" com.vertica.solutions.kafka.exception.ConfigurationException: ERROR: [No Source exists with name 'mysql-server.inventory.*' in Cluster 'my_cluster']
at com.vertica.solutions.kafka.model.StreamSource.validateConfiguration(StreamSource.java:250)
at com.vertica.solutions.kafka.model.StreamSource.setFromMapAndValidate(StreamSource.java:196)
at com.vertica.solutions.kafka.model.StreamModel.<init>(StreamModel.java:93)
at com.vertica.solutions.kafka.model.StreamSource.<init>(StreamSource.java:46)
at com.vertica.solutions.kafka.cli.SourceCLI.getNewModel(SourceCLI.java:62)
at com.vertica.solutions.kafka.cli.SourceCLI.getNewModel(SourceCLI.java:13)
at com.vertica.solutions.kafka.cli.CLI.run(CLI.java:59)
at com.vertica.solutions.kafka.cli.CLI._main(CLI.java:141)
at com.vertica.solutions.kafka.cli.SourceCLI.main(SourceCLI.java:29)
Caused by: com.vertica.solutions.kafka.exception.ConstraintValidationException: No Source exists with name 'mysql-server.inventory.*' in Cluster 'my_cluster'
at com.vertica.solutions.kafka.model.StreamSource.validateConfiguration(StreamSource.java:231)
... 8 more
