[FLINK-16398] [kafka] Make Kafka ingress/egress type strings more compact #48
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
I decided to go with the pattern:
statefun.kafka.io/universal-ingress(egress)
statefun.kafka.io/protobuf-ingress
statefun.kafka.io/generic-egress
Basically, we mention "Kafka" in the namespace, to also match the artifact name
org.apache.flink:statefun-kafka-io
, and avoid mentioning "Kafka" over and over again in the type names.mvn clean verify -Prun-e2e-tests
passes locally