Kafka + LDBC Driver Integration

[anilpacaci]

LDBC Driver generates update objects. These needs to be serialised and pushed into an update queue. Then each implementation specific consumer will consume update objects and generate implementation specific update query. (We already have gremlin consumer, we need to make gremlin producer generic producer)

[aliceranzhou]

• wrapper for KafkaProducer
• OperationExecutor for consumer
• add consumer running to WorkloadRunner ___.execute() in WR.run()
• finish Kryo Serialization

[aliceranzhou]

two modes for driver:

• update directly into db
• kafka update => flag in DbConnectionState or smth

[aliceranzhou]

ConsoleAndFileDriverConfiguration

[aliceranzhou]

OperationExecutorService OperationExecutorServiceThread Kafka Consumer OperationExecutor ContextRetriever (w/o StreamDefinition)

[aliceranzhou]

Serialization done, executor services implemented.

Remaining: implement two modes for driver

[aliceranzhou]

single kafka queue impl done