gostorm icon indicating copy to clipboard operation
gostorm copied to clipboard

Published 20 hours ago • verified publisher icon jsgilmore
→

Metadata

GoStorm is a Go library that implements the communications protocol required to write Storm spouts and Bolts in Go that communicate with the Storm shells.

Results 5 gostorm issues
Sort by recently updated
recently updated
newest added

command activate has yet not implemented on master branch

error message: panic: ShellSpout: Unknown command received from Storm: activate goroutine 1 [running]: github.com/jsgilmore/gostorm.(*shellSpoutImpl).Go(0xc0001dfb30) branch: master storm version: apache-storm-1.2.3

vrviu-victorli avatar vrviu-victorli

Need better example

3 comment

Hi, can anyone explain how I can use this library? A complete example would be nice. Your splitsentence example differs completely from the description. This is confusing. Thanks!

0xd3e avatar 0xd3e

Any Example of the config part?

Is there any example for connecting the apache storm? how to connect to apache storm using the lib?

mewwong avatar mewwong

Java based spouts?

How would you go about configuring java based spout, specifically the java based kafka spout with the golang based bolts.

anirudh-chhangani avatar anirudh-chhangani

Bolts that accept multiple streams cannot differentiate expected fields

3 comment

either Fields() needs to take a string that can help decide which interfaces get returned, or a new method FieldsForStream(string)? needs to be added to the interface that allows the...

cameront avatar cameront

enhancement

← Metadata

129
Stars
21
Forks
Watchers

Owner

verified publisher icon jsgilmore

Metadata

GoStorm is a Go library that implements the communications protocol required to write Storm spouts and Bolts in Go that communicate with the Storm shells.

Back