MobilityDB · estebanzimanyi · Jul 23, 2026 · Jul 23, 2026
diff --git a/.github/workflows/maven.yml b/.github/workflows/maven.yml
@@ -43,11 +43,10 @@ jobs:
         # libmeos is already built and installed under /usr/local by the
         # provision-meos action, so build-jmeos.sh skips its own libmeos build
         # and only builds the JMEOS jar from JMEOS main, installs it into the
-        # local Maven repo, and stages libmeos.so under kafka-streams-app/lib.
+        # local Maven repo, and stages libmeos.so under the reactor-root lib/.
         run: JOBS=2 ./build-jmeos.sh
 
       - name: Test the Kafka Streams app
         # The generated MeosOps* facades forward to the installed JMEOS jar; the tests
         # exercise them against the freshly built libmeos, resolved via LD_LIBRARY_PATH.
-        working-directory: kafka-streams-app
         run: LD_LIBRARY_PATH="$PWD/lib" mvn -B test
diff --git a/.gitignore b/.gitignore
@@ -7,8 +7,8 @@ tools/meos-idl.json
 
 # JMEOS native dependency — generated by build-jmeos.sh, never committed
 .build-jmeos/
-kafka-streams-app/jar/
-kafka-streams-app/lib/
+jar/
+lib/
 *.jar
 *.so
 

diff --git a/kafka-streams-app/docs/benchmark.md → benchmark/docs/benchmark.md b/kafka-streams-app/docs/benchmark.md → benchmark/docs/benchmark.md
diff --git a/benchmark/pom.xml b/benchmark/pom.xml
@@ -0,0 +1,131 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>com.mobilitydb.kafka</groupId>
+        <artifactId>mobility-kafka-parent</artifactId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>mobility-kafka-benchmark</artifactId>
+
+    <!-- The BerlinMOD streaming benchmark: a Kafka Streams application built on the binding.
+         Its MEOS access goes entirely through the binding's generated surface. -->
+
+    <dependencies>
+        <dependency>
+            <groupId>com.mobilitydb.kafka</groupId>
+            <artifactId>mobility-kafka-binding</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>${jackson.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>${slf4j.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-simple</artifactId>
+            <version>${slf4j.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-streams-test-utils</artifactId>
+            <version>${kafka.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <version>${junit.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-engine</artifactId>
+            <version>${junit.version}</version>
+            <scope>test</scope>
+        </dependency>
+
+        <!-- Embedded Kafka broker for the runtime throughput benchmark. -->
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka_2.13</artifactId>
+            <version>${kafka.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka_2.13</artifactId>
+            <version>${kafka.version}</version>
+            <type>test-jar</type><classifier>test</classifier><scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-streams</artifactId>
+            <version>${kafka.version}</version>
+            <type>test-jar</type><classifier>test</classifier><scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-clients</artifactId>
+            <version>${kafka.version}</version>
+            <type>test-jar</type><classifier>test</classifier><scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-server-common</artifactId>
+            <version>${kafka.version}</version>
+            <type>test-jar</type><classifier>test</classifier><scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.hamcrest</groupId>
+            <artifactId>hamcrest</artifactId>
+            <version>2.2</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <artifactId>maven-shade-plugin</artifactId>
+                <version>3.5.1</version>
+                <executions>
+                    <execution>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>shade</goal>
+                        </goals>
+                        <configuration>
+                            <createDependencyReducedPom>false</createDependencyReducedPom>
+                            <transformers>
+                                <transformer implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/>
+                            </transformers>
+                            <filters>
+                                <filter>
+                                    <artifact>*:*</artifact>
+                                    <excludes>
+                                        <exclude>META-INF/*.SF</exclude>
+                                        <exclude>META-INF/*.DSA</exclude>
+                                        <exclude>META-INF/*.RSA</exclude>
+                                    </excludes>
+                                </filter>
+                            </filters>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>
diff --git a/.../main/java/berlinmod/BerlinMODCorpus.java → .../main/java/berlinmod/BerlinMODCorpus.java b/.../main/java/berlinmod/BerlinMODCorpus.java → .../main/java/berlinmod/BerlinMODCorpus.java
diff --git a/...ain/java/berlinmod/BerlinMODTopology.java → ...ain/java/berlinmod/BerlinMODTopology.java b/...ain/java/berlinmod/BerlinMODTopology.java → ...ain/java/berlinmod/BerlinMODTopology.java
diff --git a/...rc/main/java/berlinmod/BerlinMODTrip.java → ...rc/main/java/berlinmod/BerlinMODTrip.java b/...rc/main/java/berlinmod/BerlinMODTrip.java → ...rc/main/java/berlinmod/BerlinMODTrip.java
diff --git a/...in/java/berlinmod/BerlinMODTripSerde.java → ...in/java/berlinmod/BerlinMODTripSerde.java b/...in/java/berlinmod/BerlinMODTripSerde.java → ...in/java/berlinmod/BerlinMODTripSerde.java
diff --git a/...pp/src/main/java/berlinmod/Haversine.java → ...rk/src/main/java/berlinmod/Haversine.java b/...pp/src/main/java/berlinmod/Haversine.java → ...rk/src/main/java/berlinmod/Haversine.java
diff --git a/...p/src/main/java/berlinmod/MEOSBridge.java → ...k/src/main/java/berlinmod/MEOSBridge.java b/...p/src/main/java/berlinmod/MEOSBridge.java → ...k/src/main/java/berlinmod/MEOSBridge.java
diff --git a/.../main/java/berlinmod/PointOfInterest.java → .../main/java/berlinmod/PointOfInterest.java b/.../main/java/berlinmod/PointOfInterest.java → .../main/java/berlinmod/PointOfInterest.java
diff --git a/...java/berlinmod/Q1ContinuousProcessor.java → ...java/berlinmod/Q1ContinuousProcessor.java b/...java/berlinmod/Q1ContinuousProcessor.java → ...java/berlinmod/Q1ContinuousProcessor.java
diff --git a/...n/java/berlinmod/Q1SnapshotProcessor.java → ...n/java/berlinmod/Q1SnapshotProcessor.java b/...n/java/berlinmod/Q1SnapshotProcessor.java → ...n/java/berlinmod/Q1SnapshotProcessor.java
diff --git a/...n/java/berlinmod/Q1WindowedProcessor.java → ...n/java/berlinmod/Q1WindowedProcessor.java b/...n/java/berlinmod/Q1WindowedProcessor.java → ...n/java/berlinmod/Q1WindowedProcessor.java
diff --git a/...java/berlinmod/Q2ContinuousProcessor.java → ...java/berlinmod/Q2ContinuousProcessor.java b/...java/berlinmod/Q2ContinuousProcessor.java → ...java/berlinmod/Q2ContinuousProcessor.java
diff --git a/...n/java/berlinmod/Q2SnapshotProcessor.java → ...n/java/berlinmod/Q2SnapshotProcessor.java b/...n/java/berlinmod/Q2SnapshotProcessor.java → ...n/java/berlinmod/Q2SnapshotProcessor.java
diff --git a/...n/java/berlinmod/Q2WindowedProcessor.java → ...n/java/berlinmod/Q2WindowedProcessor.java b/...n/java/berlinmod/Q2WindowedProcessor.java → ...n/java/berlinmod/Q2WindowedProcessor.java
diff --git a/...java/berlinmod/Q3ContinuousProcessor.java → ...java/berlinmod/Q3ContinuousProcessor.java b/...java/berlinmod/Q3ContinuousProcessor.java → ...java/berlinmod/Q3ContinuousProcessor.java
diff --git a/...n/java/berlinmod/Q3SnapshotProcessor.java → ...n/java/berlinmod/Q3SnapshotProcessor.java b/...n/java/berlinmod/Q3SnapshotProcessor.java → ...n/java/berlinmod/Q3SnapshotProcessor.java
diff --git a/...n/java/berlinmod/Q3WindowedProcessor.java → ...n/java/berlinmod/Q3WindowedProcessor.java b/...n/java/berlinmod/Q3WindowedProcessor.java → ...n/java/berlinmod/Q3WindowedProcessor.java
diff --git a/...java/berlinmod/Q4ContinuousProcessor.java → ...java/berlinmod/Q4ContinuousProcessor.java b/...java/berlinmod/Q4ContinuousProcessor.java → ...java/berlinmod/Q4ContinuousProcessor.java
diff --git a/...n/java/berlinmod/Q4SnapshotProcessor.java → ...n/java/berlinmod/Q4SnapshotProcessor.java b/...n/java/berlinmod/Q4SnapshotProcessor.java → ...n/java/berlinmod/Q4SnapshotProcessor.java
diff --git a/...n/java/berlinmod/Q4WindowedProcessor.java → ...n/java/berlinmod/Q4WindowedProcessor.java b/...n/java/berlinmod/Q4WindowedProcessor.java → ...n/java/berlinmod/Q4WindowedProcessor.java
diff --git a/...java/berlinmod/Q5ContinuousProcessor.java → ...java/berlinmod/Q5ContinuousProcessor.java b/...java/berlinmod/Q5ContinuousProcessor.java → ...java/berlinmod/Q5ContinuousProcessor.java
diff --git a/...n/java/berlinmod/Q5SnapshotProcessor.java → ...n/java/berlinmod/Q5SnapshotProcessor.java b/...n/java/berlinmod/Q5SnapshotProcessor.java → ...n/java/berlinmod/Q5SnapshotProcessor.java
diff --git a/...n/java/berlinmod/Q5WindowedProcessor.java → ...n/java/berlinmod/Q5WindowedProcessor.java b/...n/java/berlinmod/Q5WindowedProcessor.java → ...n/java/berlinmod/Q5WindowedProcessor.java
diff --git a/...java/berlinmod/Q6ContinuousProcessor.java → ...java/berlinmod/Q6ContinuousProcessor.java b/...java/berlinmod/Q6ContinuousProcessor.java → ...java/berlinmod/Q6ContinuousProcessor.java
diff --git a/...n/java/berlinmod/Q6SnapshotProcessor.java → ...n/java/berlinmod/Q6SnapshotProcessor.java b/...n/java/berlinmod/Q6SnapshotProcessor.java → ...n/java/berlinmod/Q6SnapshotProcessor.java
diff --git a/...n/java/berlinmod/Q6WindowedProcessor.java → ...n/java/berlinmod/Q6WindowedProcessor.java b/...n/java/berlinmod/Q6WindowedProcessor.java → ...n/java/berlinmod/Q6WindowedProcessor.java
diff --git a/...java/berlinmod/Q7ContinuousProcessor.java → ...java/berlinmod/Q7ContinuousProcessor.java b/...java/berlinmod/Q7ContinuousProcessor.java → ...java/berlinmod/Q7ContinuousProcessor.java
diff --git a/...n/java/berlinmod/Q7SnapshotProcessor.java → ...n/java/berlinmod/Q7SnapshotProcessor.java b/...n/java/berlinmod/Q7SnapshotProcessor.java → ...n/java/berlinmod/Q7SnapshotProcessor.java
diff --git a/...n/java/berlinmod/Q7WindowedProcessor.java → ...n/java/berlinmod/Q7WindowedProcessor.java b/...n/java/berlinmod/Q7WindowedProcessor.java → ...n/java/berlinmod/Q7WindowedProcessor.java
diff --git a/...java/berlinmod/Q8ContinuousProcessor.java → ...java/berlinmod/Q8ContinuousProcessor.java b/...java/berlinmod/Q8ContinuousProcessor.java → ...java/berlinmod/Q8ContinuousProcessor.java
diff --git a/...n/java/berlinmod/Q8SnapshotProcessor.java → ...n/java/berlinmod/Q8SnapshotProcessor.java b/...n/java/berlinmod/Q8SnapshotProcessor.java → ...n/java/berlinmod/Q8SnapshotProcessor.java
diff --git a/...n/java/berlinmod/Q8WindowedProcessor.java → ...n/java/berlinmod/Q8WindowedProcessor.java b/...n/java/berlinmod/Q8WindowedProcessor.java → ...n/java/berlinmod/Q8WindowedProcessor.java
diff --git a/...java/berlinmod/Q9ContinuousProcessor.java → ...java/berlinmod/Q9ContinuousProcessor.java b/...java/berlinmod/Q9ContinuousProcessor.java → ...java/berlinmod/Q9ContinuousProcessor.java
diff --git a/...n/java/berlinmod/Q9SnapshotProcessor.java → ...n/java/berlinmod/Q9SnapshotProcessor.java b/...n/java/berlinmod/Q9SnapshotProcessor.java → ...n/java/berlinmod/Q9SnapshotProcessor.java
diff --git a/...n/java/berlinmod/Q9WindowedProcessor.java → ...n/java/berlinmod/Q9WindowedProcessor.java b/...n/java/berlinmod/Q9WindowedProcessor.java → ...n/java/berlinmod/Q9WindowedProcessor.java
diff --git a/.../main/java/berlinmod/SegmentDistance.java → .../main/java/berlinmod/SegmentDistance.java b/.../main/java/berlinmod/SegmentDistance.java → .../main/java/berlinmod/SegmentDistance.java
diff --git a/...s-app/src/main/resources/log4j.properties → ...hmark/src/main/resources/log4j.properties b/...s-app/src/main/resources/log4j.properties → ...hmark/src/main/resources/log4j.properties
diff --git a/...st/java/berlinmod/BerlinMODBenchmark.java → ...st/java/berlinmod/BerlinMODBenchmark.java b/...st/java/berlinmod/BerlinMODBenchmark.java → ...st/java/berlinmod/BerlinMODBenchmark.java
diff --git a/...va/berlinmod/BerlinMODFullMatrixTest.java → ...va/berlinmod/BerlinMODFullMatrixTest.java b/...va/berlinmod/BerlinMODFullMatrixTest.java → ...va/berlinmod/BerlinMODFullMatrixTest.java
diff --git a/...va/berlinmod/BerlinMODSetSetJoinTest.java → ...va/berlinmod/BerlinMODSetSetJoinTest.java b/...va/berlinmod/BerlinMODSetSetJoinTest.java → ...va/berlinmod/BerlinMODSetSetJoinTest.java
diff --git a/...va/berlinmod/EmbeddedBrokerBenchmark.java → ...va/berlinmod/EmbeddedBrokerBenchmark.java b/...va/berlinmod/EmbeddedBrokerBenchmark.java → ...va/berlinmod/EmbeddedBrokerBenchmark.java
diff --git a/...p/src/test/resources/berlinmod_sample.csv → ...k/src/test/resources/berlinmod_sample.csv b/...p/src/test/resources/berlinmod_sample.csv → ...k/src/test/resources/berlinmod_sample.csv
diff --git a/binding/pom.xml b/binding/pom.xml
@@ -0,0 +1,117 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>com.mobilitydb.kafka</groupId>
+        <artifactId>mobility-kafka-parent</artifactId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>mobility-kafka-binding</artifactId>
+
+    <!-- The Kafka MEOS binding: the org.mobilitydb.meos.MeosOps* facades generated from the
+         JMEOS catalog at build time, plus the generic Kafka Streams wiring layer over them.
+         A pure projection of the MEOS surface — no application or benchmark code. -->
+
+    <dependencies>
+        <dependency>
+            <groupId>com.mobilitydb</groupId>
+            <artifactId>jmeos</artifactId>
+            <version>${jmeos.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.github.jnr</groupId>
+            <artifactId>jnr-ffi</artifactId>
+            <version>${jnr.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-streams</artifactId>
+            <version>${kafka.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>${slf4j.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-simple</artifactId>
+            <version>${slf4j.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-streams-test-utils</artifactId>
+            <version>${kafka.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <version>${junit.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-engine</artifactId>
+            <version>${junit.version}</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <!-- Generate the org.mobilitydb.meos.MeosOps* facades from the installed JMEOS jar's
+                 surface at build time (into target/, never committed), via the single generator
+                 vendored identically by every JVM binding. -->
+            <plugin>
+                <groupId>org.codehaus.mojo</groupId>
+                <artifactId>exec-maven-plugin</artifactId>
+                <version>3.1.0</version>
+                <executions>
+                    <execution>
+                        <id>generate-facades</id>
+                        <phase>generate-sources</phase>
+                        <goals><goal>exec</goal></goals>
+                        <configuration>
+                            <executable>python3</executable>
+                            <arguments>
+                                <argument>${project.basedir}/../tools/codegen_jvm.py</argument>
+                                <argument>--engine</argument>
+                                <argument>kafka</argument>
+                                <argument>--catalog</argument>
+                                <argument>${project.basedir}/../tools/meos-idl.json</argument>
+                                <argument>--jar</argument>
+                                <argument>${settings.localRepository}/com/mobilitydb/jmeos/${jmeos.version}/jmeos-${jmeos.version}.jar</argument>
+                                <argument>--out</argument>
+                                <argument>${project.build.directory}/generated-facades</argument>
+                            </arguments>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.codehaus.mojo</groupId>
+                <artifactId>build-helper-maven-plugin</artifactId>
+                <version>3.5.0</version>
+                <executions>
+                    <execution>
+                        <id>add-generated-facades</id>
+                        <phase>generate-sources</phase>
+                        <goals><goal>add-source</goal></goals>
+                        <configuration>
+                            <sources>
+                                <source>${project.build.directory}/generated-facades/src/main/java</source>
+                            </sources>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>
diff --git a/...os/wirings/MeosBoundedStateProcessor.java → ...os/wirings/MeosBoundedStateProcessor.java b/...os/wirings/MeosBoundedStateProcessor.java → ...os/wirings/MeosBoundedStateProcessor.java
diff --git a/...a/meos/wirings/MeosCrossStreamJoiner.java → ...a/meos/wirings/MeosCrossStreamJoiner.java b/...a/meos/wirings/MeosCrossStreamJoiner.java → ...a/meos/wirings/MeosCrossStreamJoiner.java
diff --git a/...db/kafka/meos/wirings/MeosOpsRuntime.java → ...db/kafka/meos/wirings/MeosOpsRuntime.java b/...db/kafka/meos/wirings/MeosOpsRuntime.java → ...db/kafka/meos/wirings/MeosOpsRuntime.java
diff --git a/.../kafka/meos/wirings/MeosStatelessOps.java → .../kafka/meos/wirings/MeosStatelessOps.java b/.../kafka/meos/wirings/MeosStatelessOps.java → .../kafka/meos/wirings/MeosStatelessOps.java
diff --git a/.../meos/wirings/MeosWindowedAggregator.java → .../meos/wirings/MeosWindowedAggregator.java b/.../meos/wirings/MeosWindowedAggregator.java → .../meos/wirings/MeosWindowedAggregator.java
diff --git a/...g/mobilitydb/kafka/meos/wirings/README.md → ...g/mobilitydb/kafka/meos/wirings/README.md b/...g/mobilitydb/kafka/meos/wirings/README.md → ...g/mobilitydb/kafka/meos/wirings/README.md
diff --git a/...a/org/mobilitydb/meos/MeosSetSetJoin.java → ...a/org/mobilitydb/meos/MeosSetSetJoin.java b/...a/org/mobilitydb/meos/MeosSetSetJoin.java → ...a/org/mobilitydb/meos/MeosSetSetJoin.java
diff --git a/...tydb/kafka/meos/MeosCbufferSmokeTest.java → ...tydb/kafka/meos/MeosCbufferSmokeTest.java b/...tydb/kafka/meos/MeosCbufferSmokeTest.java → ...tydb/kafka/meos/MeosCbufferSmokeTest.java
diff --git a/...itydb/kafka/meos/MeosFacadeSmokeTest.java → ...itydb/kafka/meos/MeosFacadeSmokeTest.java b/...itydb/kafka/meos/MeosFacadeSmokeTest.java → ...itydb/kafka/meos/MeosFacadeSmokeTest.java
diff --git a/...itydb/kafka/meos/MeosNpointSmokeTest.java → ...itydb/kafka/meos/MeosNpointSmokeTest.java b/...itydb/kafka/meos/MeosNpointSmokeTest.java → ...itydb/kafka/meos/MeosNpointSmokeTest.java
diff --git a/...ilitydb/kafka/meos/MeosPoseSmokeTest.java → ...ilitydb/kafka/meos/MeosPoseSmokeTest.java b/...ilitydb/kafka/meos/MeosPoseSmokeTest.java → ...ilitydb/kafka/meos/MeosPoseSmokeTest.java
diff --git a/...wirings/demo/MeosWiringsDemoTopology.java → ...wirings/demo/MeosWiringsDemoTopology.java b/...wirings/demo/MeosWiringsDemoTopology.java → ...wirings/demo/MeosWiringsDemoTopology.java
diff --git a/build-jmeos.sh b/build-jmeos.sh
@@ -17,10 +17,10 @@
 #   3. Registers the jar in the local Maven repository via
 #      `mvn install:install-file` under the coordinates the kafka-streams-app
 #      pom depends on (com.mobilitydb:jmeos:1.4.0 by default).
-#   4. Copies libmeos.so into kafka-streams-app/lib/ for the test/runtime
+#   4. Copies libmeos.so into the reactor-root lib/ for the test/runtime
 #      LD_LIBRARY_PATH.
 #
-# After running this once, `cd kafka-streams-app && mvn test` resolves JMEOS as
+# After running this once, `mvn test` resolves JMEOS as
 # an ordinary dependency — no committed jar/so required.
 #
 # The refs below track upstream MobilityDB master and MobilityDB/JMEOS main — the
@@ -51,7 +51,7 @@ JMEOS_VERSION="${JMEOS_VERSION:-1.4.0}"
 # Layout.
 # ---------------------------------------------------------------------------
 SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
-APP_DIR="${SCRIPT_DIR}/kafka-streams-app"
+APP_DIR="${SCRIPT_DIR}"
 WORK_DIR="${WORK_DIR:-${SCRIPT_DIR}/.build-jmeos}"
 JOBS="${JOBS:-$(nproc 2>/dev/null || echo 4)}"