|
@@ -73,10 +73,6 @@ func NewConsumer(client *Client, topic string, partition int32, group string, co
|
|
|
config = new(ConsumerConfig)
|
|
config = new(ConsumerConfig)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- if config.MaxWaitTime < 100 {
|
|
|
|
|
- Logger.Println("ConsumerConfig{MaxWaitTime} is very low. This can cause high CPU and network usage. Consider increasing this value.")
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
if config.DefaultFetchSize < 0 {
|
|
if config.DefaultFetchSize < 0 {
|
|
|
return nil, ConfigurationError("Invalid DefaultFetchSize")
|
|
return nil, ConfigurationError("Invalid DefaultFetchSize")
|
|
|
} else if config.DefaultFetchSize == 0 {
|
|
} else if config.DefaultFetchSize == 0 {
|
|
@@ -95,6 +91,8 @@ func NewConsumer(client *Client, topic string, partition int32, group string, co
|
|
|
|
|
|
|
|
if config.MaxWaitTime < 0 {
|
|
if config.MaxWaitTime < 0 {
|
|
|
return nil, ConfigurationError("Invalid MaxWaitTime")
|
|
return nil, ConfigurationError("Invalid MaxWaitTime")
|
|
|
|
|
+ } else if config.MaxWaitTime < 100 {
|
|
|
|
|
+ Logger.Println("ConsumerConfig{MaxWaitTime} is very low. This can cause high CPU and network usage. Consider increasing this value.")
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
if config.EventBufferSize < 0 {
|
|
if config.EventBufferSize < 0 {
|