Simple solution to use Alpakka Kafka connector to produce and consume kafka messages.
I assume that you have 2 scala apps, a producer and a consumer.
Add the following dependencies:
class_diagram.md |
// | |
// Grove Serial Camera Kit demo for M5Stack | |
// | |
// !! CAUTION !! | |
// This code uses M5Stack Grove I2C as Grove UART (serial port). | |
// REMOVE all I2C devices. | |
// | |
// original code: | |
// https://github.com/Seeed-Studio/Grove_Serial_Camera_Kit/blob/master/SerialCameral_DemoCode_CJ_OV528_SoftSer/SerialCameral_DemoCode_CJ_OV528_SoftSer.ino | |
// File SerialCamera_DemoCode_CJ-OV528.ino |
<link rel="import" href="../ace-element/ace-element.html"> | |
<link rel="import" href="../chart-js/chart-js.html"> | |
<link rel="import" href="../code-mirror/code-mirror.html"> | |
<polymer-element name="my-element"> | |
<template> | |
<style> | |
:host { | |
position: absolute; |
// Use Gists to store code you would like to remember later on | |
console.log(window); // log the "window" object to the console |
$ vagrant plugin install vagrant-proxyconf --debug | |
INFO global: Vagrant version: 1.4.1 | |
INFO global: Ruby version: 2.0.0 | |
INFO global: RubyGems version: 2.0.14 | |
INFO global: VAGRANT_HTTP_PROXY="http://10.10.10.10:8080/" | |
INFO global: VAGRANT_HTTPS_PROXY="http://10.10.10.10:8080/" | |
INFO global: VAGRANT_INSTALLER_EMBEDDED_DIR="/Applications/Vagrant/bin/../embedded" | |
INFO global: VAGRANT_INSTALLER_VERSION="2" | |
INFO global: VAGRANT_DETECTED_OS="Darwin" | |
INFO global: VAGRANT_INSTALLER_ENV="1" |
#!/usr/bin/env bash | |
# | |
# Startup script for jetty under *nix systems (it works under NT/cygwin too). | |
# To get the service to restart correctly on reboot, uncomment below (3 lines): | |
# ======================== | |
# chkconfig: 3 99 99 | |
# description: Jetty 7 webserver | |
# processname: jetty | |
# ======================== |
#!/usr/bin/env bash | |
# | |
# Startup script for jetty under *nix systems (it works under NT/cygwin too). | |
# To get the service to restart correctly on reboot, uncomment below (3 lines): | |
# ======================== | |
# chkconfig: 3 99 99 | |
# description: Jetty 7 webserver | |
# processname: jetty | |
# ======================== |
... |