Constant Field Values


Contents
storm.kafka.*

storm.kafka.StringScheme
public static final String STRING_SCHEME_KEY "str"

storm.kafka.bolt.KafkaBolt<K,V>
public static final String KAFKA_BROKER_PROPERTIES "kafka.broker.properties"
public static final String TOPIC "topic"

storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper<K,V>
public static final String BOLT_KEY "key"
public static final String BOLT_MESSAGE "message"

storm.kafka.trident.TridentKafkaState
public static final String KAFKA_BROKER_PROPERTIES "kafka.broker.properties"



Copyright © 2015 The Apache Software Foundation. All Rights Reserved.