Skip to content

Instantly share code, notes, and snippets.

@ChromoX
ChromoX / kafka.clj
Last active November 17, 2016 06:28
{: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
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)
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):
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)
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"
>
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
ChromoX / gist:095b81002ed8aef7b2e0
Created September 17, 2014 19:15
CUSIP to Equity Symbol
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]