ChromoX

      {:onyx/name :read-ticker-messages
       :onyx/plugin :onyx.plugin.kafka/read-messages
       :onyx/type :input
       :onyx/medium :kafka
       :kafka/topic "tick"
       :kafka/group-id "onyx-consumer"
       :kafka/receive-buffer-bytes 65536
       :kafka/zookeeper "127.0.0.1:2181"
       :kafka/offset-reset :earliest
       :kafka/force-reset? true

ChromoX

Exception in thread "main" java.lang.NullPointerException, compiling:(/private/var/folders/wp/pq4sc88554b_wmhd90g8rhjh0000gn/T/form-init8152135396385670453.clj:1:125)
	at clojure.lang.Compiler.load(Compiler.java:7391)
	at clojure.lang.Compiler.loadFile(Compiler.java:7317)
	at clojure.main$load_script.invokeStatic(main.clj:275)
	at clojure.main$init_opt.invokeStatic(main.clj:277)
	at clojure.main$init_opt.invoke(main.clj:277)
	at clojure.main$initialize.invokeStatic(main.clj:308)
	at clojure.main$null_opt.invokeStatic(main.clj:342)
	at clojure.main$null_opt.invoke(main.clj:339)
	at clojure.main$main.invokeStatic(main.clj:421)

ChromoX

zookeeper_1  | 2016-11-17 01:26:46,968 [myid:] - INFO  [ProcessThread(sid:0 cport:-1)::PrepRequestProcessor@645] - Got user-level KeeperException when processing sessionid:0x1586fe3d355000a type:create cxid:0x2 zxid:0xa4 txntype:-1 reqpath:n/a Error Path:/onyx Error:KeeperErrorCode = NodeExists for /onyx
zookeeper_1  | 2016-11-17 01:26:46,974 [myid:] - INFO  [ProcessThread(sid:0 cport:-1)::PrepRequestProcessor@645] - Got user-level KeeperException when processing sessionid:0x1586fe3d355000a type:create cxid:0x3 zxid:0xa5 txntype:-1 reqpath:n/a Error Path:/onyx/1 Error:KeeperErrorCode = NodeExists for /onyx/1
zookeeper_1  | 2016-11-17 01:26:46,980 [myid:] - INFO  [ProcessThread(sid:0 cport:-1)::PrepRequestProcessor@645] - Got user-level KeeperException when processing sessionid:0x1586fe3d355000a type:create cxid:0x4 zxid:0xa6 txntype:-1 reqpath:n/a Error Path:/onyx/1/pulse Error:KeeperErrorCode = NodeExists for /onyx/1/pulse
zookeeper_1  | 2016-11-17 01:26:46,985 [myid:] - INFO  [ProcessThread(sid:0 cport:-1):

ChromoX

Exception in thread "main" clojure.lang.ExceptionInfo: Thaw failed: Decryption/decompression failure, or data unfrozen/damaged. {:opts {:v1-compatibility? false, :compressor :auto, :encryptor :auto}}, compiling:(/private/var/folders/wp/pq4sc88554b_wmhd90g8rhjh0000gn/T/form-init5194750962193779678.clj:1:125)
	at clojure.lang.Compiler.load(Compiler.java:7391)
	at clojure.lang.Compiler.loadFile(Compiler.java:7317)
	at clojure.main$load_script.invokeStatic(main.clj:275)
	at clojure.main$init_opt.invokeStatic(main.clj:277)
	at clojure.main$init_opt.invoke(main.clj:277)
	at clojure.main$initialize.invokeStatic(main.clj:308)
	at clojure.main$null_opt.invokeStatic(main.clj:342)
	at clojure.main$null_opt.invoke(main.clj:339)
	at clojure.main$main.invokeStatic(main.clj:421)

ChromoX

Docker-Compose:

wamp-subscriber:
  tty: true
  image: registry.portman.io:5000/data-wamp-subscriber
  external_links:
    - ${zk_link}:zk_kafka
    - ${kafka_link}:kafka
  environment:
    - WAMP_URL="wss://api.mentisuel.com"

ChromoX

> 

U-Boot 2012.07 (Aug 03 2016 - 17:04:04) for Exynos5422

CPU: Exynos5422 Rev0.1 [Samsung SOC on SMP Platform Base on ARM CortexA7]
APLL = 800MHz, KPLL = 800MHz
MPLL = 532MHz, BPLL = 825MHz

Board: HardKernel ODROID
DRAM:  2 GiB

ChromoX

def cusip_to_symbol(cusip):
    req = requests.get("http://activequote.fidelity.com/mmnet/SymLookup.phtml?reqforlookup=REQUESTFORLOOKUP&productid=mmnet&isLoggedIn=mmnet&rows=50&for=stock&by=cusip&criteria=%s&submit=Search" % (cusip))
    page_html = req.text

    s_index_begin = page_html.find('<tr><td height="20" nowrap><font class="smallfont">')
    s_index_end = page_html.find('</table></td></tr>', s_index_begin)
    symbol_section = page_html[s_index_begin:s_index_end]
    s_bracket_end = symbol_section.find('</a>')
    s_bracket_begin = symbol_section.find('">', s_bracket_end - 10)
    return symbol_section[s_bracket_begin + len('">'):s_bracket_end]