1.0

README.md

@@ -1,11 +1,9 @@
+![](images/b3b3l.webp)
 
+Usage 
 
+To send a message confused with "farfallino" alphabet
+% curl -d "Salvo" http://localhost:9090
 
-mvn archetype:generate \
-    -DarchetypeGroupId=org.apache.kafka \
-    -DarchetypeArtifactId=streams-quickstart-java \
-    -DarchetypeVersion=3.9.0 \
-    -DgroupId=streams.examples \
-    -DartifactId=kafka-streams.examples \
-    -Dversion=0.1 \
-    -Dpackage=tap
+To send a message confused with "hacker" alphabet
+% curl -d "Salvo" http://localhost:9091

babel.yml

@@ -16,6 +16,7 @@ services:
       XPACK_MONITORING_ENABLED: "false"
     ports:
       - 9090:9090
+      - 9091:9091
     volumes:
       - ./logstash-babel.conf:/usr/share/logstash/pipeline/logstash.conf
     depends_on:
@@ -27,14 +28,13 @@ services:
     container_name: broker
     ports:
       - '9092:9092'
-      - '9093:9093'
     environment:
       KAFKA_NODE_ID: 1
-      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: 'CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT,DMI:PLAINTEXT'
-      KAFKA_ADVERTISED_LISTENERS: 'PLAINTEXT_HOST://broker:9092,PLAINTEXT://broker:19092,DMI://151.97.56.148:9093'
+      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: 'CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT'
+      KAFKA_ADVERTISED_LISTENERS: 'PLAINTEXT_HOST://broker:9092,PLAINTEXT://broker:19092'
       KAFKA_PROCESS_ROLES: 'broker,controller'
       KAFKA_CONTROLLER_QUORUM_VOTERS: '1@broker:29093'
-      KAFKA_LISTENERS: 'CONTROLLER://:29093,PLAINTEXT_HOST://:9092,PLAINTEXT://:19092,DMI://:9093'
+      KAFKA_LISTENERS: 'CONTROLLER://:29093,PLAINTEXT_HOST://:9092,PLAINTEXT://:19092'
       KAFKA_INTER_BROKER_LISTENER_NAME: 'PLAINTEXT'
       KAFKA_CONTROLLER_LISTENER_NAMES: 'CONTROLLER'
       CLUSTER_ID: '4L6g3nShT-eMCtK--X86sw'
@@ -53,8 +53,20 @@ services:
       - broker
   babel-stream:
     image: babel
-    command: tap.Pipe
+    command: tap.confundus
     depends_on:
       babel-topics:
         condition: service_completed_successfully
+  babel-input:
+    image: apache/kafka:latest
+    command: /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server broker:9092 --topic babel-input --formatter kafka.tools.DefaultMessageFormatter --property print.key=true --property print.value=true --property key.deserializer=org.apache.kafka.common.serialization.StringDeserializer --property value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
+    depends_on:
+      babel-topics:
+        condition: service_completed_successfully
+  babel-output:
+      image: apache/kafka:latest
+      command: /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server broker:9092 --topic babel-output --formatter kafka.tools.DefaultMessageFormatter --property print.key=true --property print.value=true --property key.deserializer=org.apache.kafka.common.serialization.StringDeserializer --property value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
+      depends_on:
+        babel-topics:
+          condition: service_completed_successfully
 

logstash-babel.conf

@@ -1,21 +1,32 @@
 input {
   http {
-    id => "tap_http_in"
+    id => "farfallino"
     port => 9090
+    add_field => { "confused_language" => "farfallino" }
   }
+
+  http {
+     id => "hacker"
+     port => 9091
+     add_field => { "confused_language" => "hacker" }
+   }
 }
 
 filter {
     if [http][method] != "POST"{
         drop {}
     }
+
+    mutate {
+        remove_field => ["@timestamp", "@version", "url", "host", "http", "event", "user_agent"]
+    }
 }
 
 output {
   kafka {
-    codec => json
+    codec => plain { format => "%{message}" }
     topic_id => "babel-input"
     bootstrap_servers => "broker:9092"
-    message_key => "farfallino"
+    message_key => "%{confused_language}"
   }
 }

stream/kafka-streams.examples/Dockerfile → stream/Dockerfile

@@ -6,14 +6,15 @@ WORKDIR /app
 COPY pom.xml .
 
 # Downloading dependencies
-RUN mvn -f ./pom.xml clean package
+RUN mvn -f ./pom.xml clean
 
 COPY src src
 
 RUN mvn -f ./pom.xml package
+CMD /bin/bash
 
 FROM apache/kafka:latest
 ENV PATH /opt/kafka/bin:$PATH
 WORKDIR /opt/kafka/
 COPY --from=build /app/target/*.jar  /opt/kafka/libs
-ENTRYPOINT [ "kafka-run-class.sh"]  
+ENTRYPOINT [ "kafka-run-class.sh"]

stream/kafka-streams.examples/pom.xml → stream/pom.xml

@@ -21,7 +21,7 @@
     <modelVersion>4.0.0</modelVersion>
 
     <groupId>streams.examples</groupId>
-    <artifactId>kafka-streams.examples</artifactId>
+    <artifactId>stream</artifactId>
     <version>0.1</version>
     <packaging>jar</packaging>
 

stream/src/main/java/tap/FarfallinoTranslator.java

@@ -0,0 +1,31 @@
+package tap;
+
+public class FarfallinoTranslator {
+
+    // Method to check if a character is a vowel
+    private static boolean isVowel(char c) {
+        return "aeiouAEIOU".indexOf(c) != -1;
+    }
+
+    // Method to translate the given string to Farfallino alphabet
+    public static String toFarfallino(String input) {
+        StringBuilder translated = new StringBuilder();
+
+        // Iterate over each character in the input string
+        for (int i = 0; i < input.length(); i++) {
+            char c = input.charAt(i);
+
+            // If the character is a vowel, apply Farfallino transformation
+            if (isVowel(c)) {
+                translated.append(c);  // Add the original vowel
+                translated.append('f'); // Add 'f'
+                translated.append(c);   // Add the same vowel again
+            } else {
+                translated.append(c);  // Add the consonant unchanged
+            }
+        }
+
+        return translated.toString();
+    }
+
+}

stream/src/main/java/tap/HackerLanguageTranslator.java

@@ -0,0 +1,31 @@
+package tap;
+
+public class HackerLanguageTranslator {
+
+    // Method to translate a character to its Hacker Language equivalent
+    private static char toHackerChar(char c) {
+        switch (Character.toLowerCase(c)) {
+            case 'a': return '4';
+            case 'e': return '3';
+            case 'i': return '1';
+            case 'o': return '0';
+            case 't': return '7';
+            default: return c; // If not a vowel or "t", keep the character unchanged
+        }
+    }
+
+    // Method to translate the given string to Hacker Language
+    public static String toHackerLanguage(String input) {
+        StringBuilder translated = new StringBuilder();
+
+        // Iterate over each character in the input string
+        for (int i = 0; i < input.length(); i++) {
+            char c = input.charAt(i);
+            translated.append(toHackerChar(c));  // Translate each character
+        }
+
+        return translated.toString();
+    }
+
+
+}