You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by bo...@apache.org on 2023/02/09 15:24:05 UTC

[streampipes] branch fix/python-add-alias created (now c7233eeb9)

This is an automated email from the ASF dual-hosted git repository.

bossenti pushed a change to branch fix/python-add-alias
in repository https://gitbox.apache.org/repos/asf/streampipes.git


      at c7233eeb9 fix(python-model): add alias to support Kafka specific port name (#1245)

This branch includes the following new commits:

     new c7233eeb9 fix(python-model): add alias to support Kafka specific port name (#1245)

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[streampipes] 01/01: fix(python-model): add alias to support Kafka specific port name (#1245)

Posted by bo...@apache.org.
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 <bo...@posteo.de>
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 <bo...@posteo.de>
---
 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):