This is an automated email from the ASF dual-hosted git repository.
spetz pushed a change to branch banner
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 97fe18755 chore: add Iggy banner to server startup
add b87b6a6f7 fix(java): size wire strings by UTF-8 byte length, not char
count (#4068)
add ab734f17f fix(connectors): validate connector key before it becomes a
path (#4083)
add 548da0adc Merge branch 'master' into banner
No new revisions were added by this update.
Summary of changes:
core/connectors/runtime/README.md | 15 ++
core/connectors/runtime/src/api/error.rs | 15 +-
.../mod.rs => connectors/runtime/src/api/key.rs} | 35 ++--
core/connectors/runtime/src/api/mod.rs | 1 +
core/connectors/runtime/src/api/sink.rs | 44 +++--
core/connectors/runtime/src/api/source.rs | 44 +++--
core/connectors/runtime/src/configs/connectors.rs | 182 +++++++++++++++++++--
.../src/configs/connectors/http_provider.rs | 12 +-
.../src/configs/connectors/local_provider.rs | 50 ++++--
core/connectors/runtime/src/error.rs | 6 +
core/connectors/runtime/src/main.rs | 30 +++-
core/integration/tests/connectors/api/endpoints.rs | 104 ++++++++++++
.../api/{config.toml => key_validation.toml} | 4 +-
.../apache/iggy/examples/async/AsyncConsumer.java | 3 +-
.../apache/iggy/client/async/MessagesClient.java | 2 +-
.../client/async/tcp/ConsumerGroupsTcpClient.java | 10 +-
.../async/tcp/PersonalAccessTokensTcpClient.java | 14 +-
.../iggy/client/async/tcp/StreamsTcpClient.java | 22 +--
.../iggy/client/async/tcp/TopicsTcpClient.java | 4 +-
.../iggy/client/async/tcp/UsersTcpClient.java | 46 +++---
.../iggy/client/async/tcp/vsr/VsrLoginCodec.java | 58 +++++--
.../org/apache/iggy/identifier/Identifier.java | 32 +++-
.../main/java/org/apache/iggy/message/Message.java | 3 +-
.../java/org/apache/iggy/message/Partitioning.java | 42 ++++-
.../org/apache/iggy/serde/BytesSerializer.java | 37 +++--
.../client/async/tcp/vsr/VsrLoginCodecTest.java | 159 ++++++++++++++++++
.../client/blocking/tcp/BytesSerializerTest.java | 109 ++++++++++--
.../client/blocking/tcp/MessagesTcpClientTest.java | 35 ++++
.../client/blocking/tcp/StreamTcpClientTest.java | 24 +++
.../org/apache/iggy/identifier/IdentifierTest.java | 49 ++++++
.../java/org/apache/iggy/message/MessageTest.java | 9 +
.../org/apache/iggy/message/PartitioningTest.java | 60 +++++++
32 files changed, 1072 insertions(+), 188 deletions(-)
copy core/{integration/tests/connectors/postgres/mod.rs =>
connectors/runtime/src/api/key.rs} (50%)
copy core/integration/tests/connectors/api/{config.toml =>
key_validation.toml} (83%)
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/vsr/VsrLoginCodecTest.java
