gamussa / juber

An Uber-like data pipeline sample app. Spring Boot, Hazelcast Jet, Kafka, Hazelcast IMDG.

Project Copenhagen: Jet Hackaton

Table of content

• Into
• How to build
• How to run

A uber-like data piplene application example

Note	inspired by James Ward’s Koober https://github.com/gAmUssA/juber

Warning

Holly War warning! Applications are written with Groovy and Kotlin.

Into

The application consists Web UI (driver and rider). A rider initiates a pick up and the driver picks her.

How to build

./gradlew clean build

How to run

a sequence of steps

• start Hazelcast Jet member

  ./gradlew jet-engine:runMember

• start embedded Kafka server

  ./gradlew kafka-server:run

• start WebApp

  ./gradlew juber-anderson:bootRun

• http://localhost:8080/rider - Rider’s UI

• http://localhost:8080/driver - Driver’s UI

juber's Issues

stop sending messages when driver arrived to rider

EOM @noctarius

Facing compilation issue

Hello,
1st Thank you for providing such kind of project here.
Facing the below compilation issues. If you don't mind can pls provide steps for compilation and run this. Here I'm new to groovy and kafka

1. Downloaded zip file with entire code
2. Imported into sts 4 as a gradle project
3. When I tried to compile this using "gradlew clean build" on project "juber-master" getting below compilation errors. Pls guide me to setup this application.

\juber-master>gradlew clean build
:jet-engine:clean
:juber-anderson:clean UP-TO-DATE
:juber-common:clean
:juber-twitter:clean UP-TO-DATE
:kafka-server:clean
:juber-common:compileJava NO-SOURCE
:juber-common:compileGroovy
:juber-common:processResources NO-SOURCE
:juber-common:classes
:juber-common:jar
:kafka-server:compileJava NO-SOURCE
:kafka-server:compileGroovy
:kafka-server:processResources
:kafka-server:classes
:kafka-server:jar
:jet-engine:compileJava
:jet-engine:compileGroovy
startup failed:
E:\WORK\practice2\juber-master\jet-engine\src\main\groovy\com\juber\hasselhoff\jet\Kafka2MapDAG.groovy: 4: unable to resolve class com.hazelcast.jet.Processors
@ line 4, column 1.
import com.hazelcast.jet.Processors
^

juber-master\jet-engine\src\main\groovy\com\juber\hasselhoff\jet\Kafka2MapDAG.groovy: 10: unable to resolve class com.hazelcast.jet.connec
tor.kafka.StreamKafkaP
@ line 10, column 1.
import static com.hazelcast.jet.connector.kafka.StreamKafkaP.streamKafka
^

.
.

19 errors

:jet-engine:compileGroovy FAILED

FAILURE: Build failed with an exception.

• What went wrong:
  Execution failed for task ':jet-engine:compileGroovy'.

Compilation failed; see the compiler error output for details.

• Try:
  Run with --stacktrace option to get the stack trace. Run with --info or --debug option to get more log output.

BUILD FAILED

Total time: 7.858 secs

Thank you