scaling tweaks

Author: slorello89

samples/bluesky-sentiment-analysis/consumer/consumer/src/main/java/com/redis/Main.java

@@ -91,6 +91,11 @@ public void run() throws IOException, InterruptedException {
 
                 String key = "com.redis.bskysentimentapi.documents.Post:" + post.getCid();
                 Set<String> hashTags = new HashSet<>(Arrays.asList(post.getHashTags()));
+                if(hashTags.contains("nsfw"))
+                {
+                    consumerGroup.acknowledge(new AckMessage(entry));
+                    continue;
+                }
 
                 if(hashTags.isEmpty()){
                     Map<String,Object> postMap = Map.of(

samples/bluesky-sentiment-analysis/start-containers.sh

@@ -2,4 +2,4 @@
 
 ./gradlew clean bootJar
 docker compose build
-docker compose up --scale consumer=3
+docker compose up --scale consumer=5