README ¶ Generic, high-performance message streaming collector. It serves client-streaming grpc connection and pushes those messages to kafka at 0.5s flush rate Expand ▾ Collapse ▴ Documentation ¶ There is no documentation for this package. Source Files ¶ View all Source files collector.go main.go producer.go schema.go Directories ¶ Show internal Expand all Path Synopsis pb schemas pb Click to show internal directories. Click to hide internal directories.