mirror of
https://github.com/apache/druid.git
synced 2025-02-07 02:28:19 +00:00
3400f601db
* move ProtoBufInputRowParser from processing module to protobuf extensions * Ported PR #3509 * add DynamicMessage * fix local test stuff that slipped in * add license header * removed redundant type name * removed commented code * fix code style * rename ProtoBuf -> Protobuf * pom.xml: shade protobuf classes, handle .desc resource file as binary file * clean up error messages * pick first message type from descriptor if not specified * fix protoMessageType null check. add test case * move protobuf-extension from contrib to core * document: add new configuration keys, and descriptions * update document. add examples * move protobuf-extension from contrib to core (2nd try) * touch * include protobuf extensions in the distribution * fix whitespace * include protobuf example in the distribution * example: create new pb obj everytime * document: use properly quoted json * fix whitespace * bump parent version to 0.10.1-SNAPSHOT * ignore Override check * touch
20 lines
396 B
Python
Executable File
20 lines
396 B
Python
Executable File
#!/usr/bin/env python
|
|
|
|
import sys
|
|
import json
|
|
|
|
from kafka import KafkaProducer
|
|
from metrics_pb2 import Metrics
|
|
|
|
|
|
producer = KafkaProducer(bootstrap_servers='localhost:9092')
|
|
topic = 'metrics_pb'
|
|
|
|
for row in iter(sys.stdin):
|
|
d = json.loads(row)
|
|
metrics = Metrics()
|
|
for k, v in d.items():
|
|
setattr(metrics, k, v)
|
|
pb = metrics.SerializeToString()
|
|
producer.send(topic, pb)
|