Merge pull request #42 from RADAR-CNS/release-0.6.2

Release 0.6.2
RADAR-base · Nov 30, 2017 · 5bda901 · 5bda901
2 parents cd5d89b + f1cf73d
commit 5bda901
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 4 deletions.
diff --git a/README.md b/README.md
@@ -14,7 +14,7 @@ repositories {
 }
 
 dependencies {
-    compile group: 'org.radarcns', name: 'radar-commons', version: '0.6.1'
+    compile group: 'org.radarcns', name: 'radar-commons', version: '0.6.2'
 }
 ```
 
@@ -26,7 +26,7 @@ repositories {
 }
 
 dependencies {
-    testCompile group: 'org.radarcns', name: 'radar-commons-testing', version: '0.6.1'
+    testCompile group: 'org.radarcns', name: 'radar-commons-testing', version: '0.6.2'
 }
 ```
 
@@ -51,7 +51,7 @@ configurations.all {
 }
 
 dependencies {
-    compile group: 'org.radarcns', name: 'radar-commons', version: '0.6.2-SNAPSHOT', changing: true
+    compile group: 'org.radarcns', name: 'radar-commons', version: '0.6.3-SNAPSHOT', changing: true
 }
 ```
 

diff --git a/build.gradle b/build.gradle
@@ -36,7 +36,7 @@ allprojects {
     // Configuration                                                             //
     //---------------------------------------------------------------------------//
 
-    version = '0.6.1'
+    version = '0.6.2'
     group = 'org.radarcns'
     ext.githubRepoName = 'RADAR-CNS/RADAR-Commons'
 

diff --git a/src/main/java/org/radarcns/producer/rest/RestSender.java b/src/main/java/org/radarcns/producer/rest/RestSender.java
@@ -226,6 +226,8 @@ public void send(List<Record<L, W>> records) throws IOException {
                     lastOffsetSent = records.get(records.size() - 1).offset;
                 } else if (response.code() == 401) {
                     throw new AuthenticationException("Cannot authenticate");
+                } else if (response.code() == 403 || response.code() == 422) {
+                    throw new AuthenticationException("Data does not match authentication");
                 } else if (response.code() == 415
                         && request.header("Accept").equals(KAFKA_REST_ACCEPT_ENCODING)) {
                     state.didConnect();