Skip to content

Commit

Permalink
Merge pull request #66 from superstreamlabs/3.5.1-beta
Browse files Browse the repository at this point in the history
3.5.1 beta
  • Loading branch information
shay23b authored May 22, 2024
2 parents 68f98f0 + ece4e6f commit 0ad83f6
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 5 deletions.
2 changes: 1 addition & 1 deletion build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -1343,7 +1343,7 @@ project(':clients') {
implementation libs.snappy
implementation libs.slf4jApi

implementation 'ai.superstream:superstream-java:1.0.7'
implementation 'ai.superstream:superstream-java:1.0.8'

compileOnly libs.jacksonDatabind // for SASL/OAUTHBEARER bearer token parsing
compileOnly libs.jacksonJDK8Datatypes
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -393,10 +393,9 @@ public class KafkaAdminClient extends AdminClient {
// ** Added by Superstream
public Superstream superstreamConnection;
public void configureSuperstream(Map<String, ?> configs) {
System.out.println("Running Superstream Kafka Admin Client");
Superstream superstreamConn = (Superstream) configs.get(Consts.superstreamConnectionKey);
if (superstreamConn == null) {
System.out.println("Failed to connect to Superstream - Running Kafka Admin Client");
System.out.println("Failed to connect to Superstream");
} else {
this.superstreamConnection = superstreamConn;
}
Expand Down
2 changes: 1 addition & 1 deletion version-beta.conf
Original file line number Diff line number Diff line change
@@ -1 +1 @@
3.5.16-beta
3.5.17-beta
2 changes: 1 addition & 1 deletion version.conf
Original file line number Diff line number Diff line change
@@ -1 +1 @@
3.5.16
3.5.17

0 comments on commit 0ad83f6

Please sign in to comment.