This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch skipping-offset
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 1d05ba5ab fix(server): prevent consumer offset skip during concurrent
produce+consume
add 681290767 refactor(java): unify blocking TCP client as wrapper over
async client (#2947)
add 513a6e342 Merge branch 'master' into skipping-offset
No new revisions were added by this update.
Summary of changes:
.../org/apache/iggy/bdd/BasicMessagingSteps.java | 2 +-
.../consumer/GettingStartedConsumer.java | 8 +-
.../producer/GettingStartedProducer.java | 12 +-
.../consumer/MessageEnvelopeConsumer.java | 8 +-
.../producer/MessageEnvelopeProducer.java | 52 ++--
.../consumer/MessageHeadersConsumer.java | 8 +-
.../producer/MessageHeadersProducer.java | 52 ++--
.../multitenant/consumer/MultiTenantConsumer.java | 13 +-
.../multitenant/producer/MultiTenantProducer.java | 13 +-
.../sinkdataproducer/SinkDataProducer.java | 58 ++--
.../iggy/examples/streambuilder/StreamBasic.java | 36 +--
.../examples/tcptls/consumer/TcpTlsConsumer.java | 8 +-
.../examples/tcptls/producer/TcpTlsProducer.java | 12 +-
foreign/java/BUILD_AND_TEST.md | 293 ---------------------
foreign/java/gradle/libs.versions.toml | 12 +-
foreign/java/java-sdk/build.gradle.kts | 6 +-
.../async/tcp/AsyncIggyTcpClientBuilder.java | 2 +-
.../blocking/tcp/ConsumerGroupsTcpClient.java | 53 +---
...cpClient.java => ConsumerOffsetsTcpClient.java} | 29 +-
.../iggy/client/blocking/tcp/FutureUtil.java} | 35 ++-
.../iggy/client/blocking/tcp/IggyTcpClient.java | 95 +++----
.../client/blocking/tcp/IggyTcpClientBuilder.java | 59 ++---
.../client/blocking/tcp/InternalTcpClient.java | 172 ------------
.../client/blocking/tcp/MessagesTcpClient.java | 61 +----
.../client/blocking/tcp/PartitionsTcpClient.java | 21 +-
.../tcp/PersonalAccessTokensTcpClient.java | 33 +--
.../iggy/client/blocking/tcp/StreamsTcpClient.java | 42 +--
.../iggy/client/blocking/tcp/SystemTcpClient.java | 27 +-
.../iggy/client/blocking/tcp/TopicsTcpClient.java | 52 +---
.../iggy/client/blocking/tcp/UsersTcpClient.java | 94 ++-----
.../iggy/client/blocking/tcp/package-info.java | 9 +
31 files changed, 327 insertions(+), 1050 deletions(-)
delete mode 100644 foreign/java/BUILD_AND_TEST.md
rename
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/blocking/tcp/{ConsumerOffsetTcpClient.java
=> ConsumerOffsetsTcpClient.java} (58%)
copy
foreign/java/java-sdk/src/{test/java/org/apache/iggy/client/blocking/tcp/UsersTcpClientTest.java
=> main/java/org/apache/iggy/client/blocking/tcp/FutureUtil.java} (50%)
delete mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/blocking/tcp/InternalTcpClient.java
