tenthe opened a new issue, #1245:
URL: https://github.com/apache/streampipes/issues/1245
### Body
The class `KafkaTransportProtocol` uses the name `kafkaPort` protocol.
All the other transport protocols use the variable name `port`.
This should be harmonized.
I found the problem when I used the python client with a StreamPipes
instance that uses kafka as the broker.
Then I tried to read the data streams (e.g. `client.dataStreamApi.all()`)
and got the following error:
```
StreamPipesDataModelError:
Oops, there seems to be a problem with our internal StreamPipes data model.
This should not occur, but unfortunately did.
Therefore, it would be great if you could report this problem as an issue at
github.com/apache/streampipes.
Please don't forget to include the following information:
Affected Model class: <class
'streampipes.model.resource.data_stream.DataStream'>
Validation error log: [
{
"loc": [
"eventGrounding",
"transportProtocols",
0,
"port"
],
"msg": "field required",
"type": "value_error.missing"
}
]
```
### StreamPipes Committer
I acknowledge that I am a maintainer/committer of the Apache StreamPipes
project.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
