Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

KafkaFirehoseFactory: Fix serialization

This commit is contained in:
Gian Merlino 2013-03-11 11:13:19 -07:00
parent f8d9a3b19b
commit 4126893ba3
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
realtime/src/main/java/com/metamx/druid/realtime/KafkaFirehoseFactory.java
View File

@ -50,8 +50,13 @@ public class KafkaFirehoseFactory implements FirehoseFactory
{ {
private static final Logger log = new Logger(KafkaFirehoseFactory.class); private static final Logger log = new Logger(KafkaFirehoseFactory.class);
@JsonProperty
private final Properties consumerProps; private final Properties consumerProps;
@JsonProperty
private final String feed; private final String feed;
@JsonProperty
private final StringInputRowParser parser; private final StringInputRowParser parser;
@JsonCreator @JsonCreator