duanebester

def bufferedImageToMat = Flow[BufferedImage].map(bi => {
  val mat = new Mat(bi.getHeight, bi.getWidth, CV_8UC(3))
  val indexer:UByteRawIndexer = mat.createIndexer()
  for (y <- 0 until bi.getHeight()) {
    for (x <- 0 until bi.getWidth()) {
      val rgb = bi.getRGB(x, y)
      indexer.put(y, x, 0, (rgb >> 0) & 0xFF)
      indexer.put(y, x, 1, (rgb >> 8) & 0xFF)
      indexer.put(y, x, 2, (rgb >> 16) & 0xFF)
    }

duanebester

import org.bytedeco.javacpp.{opencv_photo => Photo}
def enhanceMat = Flow[Mat].map(mat => {
  val src = mat.clone()
  Photo.fastNlMeansDenoising(mat, src, 40, 10, 40)
  val dst = src.clone()
  Photo.detailEnhance(src,dst)
  dst
})

duanebester

// Add class wrapping String for JSON Streaming
case class OcrString(ocr:String)

def imageOcr = Flow[BufferedImage].map(bi => {
  val ocr = tesseract.doOCR(bi)
  OcrString(ocr)
})

// Update route
path("image" / "ocr") {

duanebester

name := "kafka-test"
version := "0.1"
scalaVersion := "2.12.7"

libraryDependencies += "com.typesafe" % "config" % "1.3.3"
libraryDependencies += "com.typesafe.akka" %% "akka-stream-kafka" % "1.0-M1"

duanebester

akka {
  kafka {
    producer {
      parallelism = 10
      close-timeout = 60s
      use-dispatcher = "akka.kafka.default-dispatcher"
      eos-commit-interval = 100ms
      kafka-clients {
        bootstrap.servers = "localhost:9092"
      }

duanebester

import akka.actor.ActorSystem
import akka.kafka.{ConsumerSettings, Subscriptions}
import akka.kafka.scaladsl.Consumer
import akka.stream.scaladsl.Sink
import akka.stream.{ActorMaterializer, Materializer}
import com.typesafe.config.ConfigFactory
import org.apache.kafka.common.serialization.StringDeserializer

import scala.concurrent.ExecutionContextExecutor
import scala.util.{Failure, Success}

duanebester

import akka.Done
import akka.actor.ActorSystem
import akka.kafka.ProducerSettings
import akka.kafka.scaladsl.Producer
import akka.stream.scaladsl.Source
import akka.stream.{ActorMaterializer, Materializer}
import com.typesafe.config.ConfigFactory
import org.apache.kafka.clients.producer.ProducerRecord
import org.apache.kafka.common.serialization.StringSerializer

duanebester

-<div>
-  <ru-page-header class="admin">
-    <main-left>
-      <h1>Product Manager</h1>
-    </main-left>
-    <main-right>
-      <a href="#/product_pages/new">
-        <button class="primary">Create New Product</button>
- 

duanebester

 import './productPageAdmin.scss';
 import template from './productPageAdmin.html';
+import {react2angular} from 'react2angular';
+import ProductManager from 'components/pages/admin/productManager';
 
 const productPageAdmin = angular.module('productPageAdmin', [grid, resources, editProduct]);
+
+productPageAdmin.component('productManager', react2angular(ProductManager));
+

duanebester

import React, {Suspense} from 'react';
import {BrowserRouter as Router, Route} from 'react-router-dom';

import ProductManagerIndex from './ProductManagerIndex';
const ProductManagerCreate = React.lazy(() => import('./ProductManagerCreate'));

export default function ProductManager () {
  return (
    <Suspense fallback={<div>Loading...</div>}>
      <Router>