fix(route-kafka.xml) : nouvelle route avec dacoupage par agence.

#31
opt-nc · Apr 26, 2023 · d7ab790 · d7ab790
1 parent ead88ff
commit d7ab790
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 12 deletions.
diff --git a/scripts/quickstart.sh b/scripts/quickstart.sh
@@ -3,7 +3,6 @@
 # Variables
 BROKER="localhost:9094"
 TOPIC="temps-attente"
-DELIMITER="idAgence"
 
 # URL RedPanda
 URL="http://0.0.0.0:8081/topics/$TOPIC?o=-1&p=-1&q&s=50#messages"
@@ -23,7 +22,7 @@ if #sudo docker exec -it kafka_tps_attente_kml kafka-topics.sh --bootstrap-serve
 else
     # créer un nouveau topic
     #docker exec -it kafka_tps_attente_kml kafka-console-producer.sh --broker-list $BROKER --topic $TOPIC
-    sudo docker exec -it kafka_tps_attente_kml kafka-topics.sh --bootstrap-server $BROKER --create --topic $TOPIC parse.key=true --property key.separator=$DELIMITER --partitions 1 --replication-factor 1
+    sudo docker exec -it kafka_tps_attente_kml kafka-topics.sh --bootstrap-server $BROKER --create --topic $TOPIC --partitions 1 --replication-factor 1
 
     # vérifier si la création du topic est réussie
     if [ $? -eq 0 ]; then

diff --git a/scripts/route-kafka.xml b/scripts/route-kafka.xml
@@ -20,15 +20,15 @@
         <unmarshal>
             <json library="Jackson" prettyPrint="false" />
         </unmarshal>
-
-        <!-- JSON -->
-        <!-- Conversion des données au format JSON -->
-        <marshal>
-            <json library="Jackson" prettyPrint="false" />
-        </marshal>
 
-        <!-- URL de destination Kafka et paramétrage de la clé -->
-        <to uri="kafka:temps-attente?brokers=127.0.0.1:9094&amp;key=idAgence"/>
-
+        <!-- Split le contenu en plusieurs messages -->
+        <split>
+            <simple>${body}</simple>
+            <to uri="kafka:temps-attente?brokers=127.0.0.1:9094&amp;key=idAgence"/>
+        </split>
+
     </route>
-</routes>
+
+</routes>
+
+