Kafka中'fetch.message.max.bytes'的關鍵定義

Question

我不確定如何爲我的KafkaSpouts的郵件大小定義關鍵字。 我的例子：

Map<String, Object> props = new HashMap<>(); 
props.put("fetch.message.max.bytes", "2097152"); // 2MB 
props.put(KafkaSpoutConfig.Consumer.GROUP_ID, group); 

我搜索沒有成功的"fetch.message.max.bytes"不斷鍵定義。 我希望這個密鑰在KafkaSpoutConfig.Consumer或至少KafkaSpoutConfig。

任何人都知道正確的位置？

Answer 1

Storm的KafkaSpout不提供所有可用密鑰作爲perdefined成員。但是，如果您知道密鑰的名稱，則可以安全地使用一個字符串（如您的示例中所示）使用定義密鑰的Kafka類。