Log a single error line for KafkaException exceptions when polling
Fixes #31
This commit is contained in:
parent
623aa6b10a
commit
5df6083e6d
|
@ -10,14 +10,11 @@ import kafka.cluster.Broker
|
||||||
import kafka.client.ClientUtils
|
import kafka.client.ClientUtils
|
||||||
import kafka.consumer.SimpleConsumer
|
import kafka.consumer.SimpleConsumer
|
||||||
import kafka.common.TopicAndPartition
|
import kafka.common.TopicAndPartition
|
||||||
|
import kafka.common.KafkaException
|
||||||
import kafka.javaapi.*
|
import kafka.javaapi.*
|
||||||
/* UGH */
|
/* UGH */
|
||||||
import scala.collection.JavaConversions
|
import scala.collection.JavaConversions
|
||||||
|
|
||||||
/* Can't type check this because it makes the calls in and out of Scala an
|
|
||||||
* atrocious pain in the ass
|
|
||||||
*/
|
|
||||||
//@TypeChecked
|
|
||||||
class KafkaPoller extends Thread {
|
class KafkaPoller extends Thread {
|
||||||
private final Integer POLLER_DELAY = (1 * 1000)
|
private final Integer POLLER_DELAY = (1 * 1000)
|
||||||
private final String KAFKA_CLIENT_ID = 'VerspaetungClient'
|
private final String KAFKA_CLIENT_ID = 'VerspaetungClient'
|
||||||
|
@ -58,6 +55,9 @@ class KafkaPoller extends Thread {
|
||||||
try {
|
try {
|
||||||
dumpMetadata()
|
dumpMetadata()
|
||||||
}
|
}
|
||||||
|
catch (KafkaException kex) {
|
||||||
|
logger.error("Failed to interact with Kafka: ${kex.message}")
|
||||||
|
}
|
||||||
catch (Exception ex) {
|
catch (Exception ex) {
|
||||||
logger.error("Failed to fetch and dump Kafka metadata", ex)
|
logger.error("Failed to fetch and dump Kafka metadata", ex)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue