This is an automated email from the ASF dual-hosted git repository. bossenti pushed a commit to branch fix/python-add-alias in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit c7233eeb9a5ee1034165c71aa30480576377473f Author: bossenti <[email protected]> AuthorDate: Thu Feb 9 16:23:48 2023 +0100 fix(python-model): add alias to support Kafka specific port name (#1245) Signed-off-by: bossenti <[email protected]> --- streampipes-client-python/streampipes/model/common.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streampipes-client-python/streampipes/model/common.py b/streampipes-client-python/streampipes/model/common.py index c72cba3d8..a9dfcbc5a 100644 --- a/streampipes-client-python/streampipes/model/common.py +++ b/streampipes-client-python/streampipes/model/common.py @@ -127,7 +127,7 @@ class TransportProtocol(BasicModel): element_id: Optional[StrictStr] broker_hostname: StrictStr topic_definition: TopicDefinition - port: StrictInt + port: StrictInt = Field(alias="kafkaPort") class TransportFormat(BasicModel):
