[ https://issues.apache.org/jira/browse/KAFKA-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149120#comment-16149120 ]
Ismael Juma commented on KAFKA-5766: ------------------------------------ I don't understand, sorry. You are saying that you don't see the issue with spring kafka, but you see it with the example code above? And using the 0.11.0.0 clients library? > Very high CPU-load of consumer when broker is down > -------------------------------------------------- > > Key: KAFKA-5766 > URL: https://issues.apache.org/jira/browse/KAFKA-5766 > Project: Kafka > Issue Type: Bug > Components: consumer > Reporter: Sebastian Bernauer > > Hi, > i have a single broker instance at localhost. > I set up a Consumer with the following code: > {code:java} > Map<String, Object> configs = new HashMap<>(); > configs.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, > "localhost:9092"); > configs.put(ConsumerConfig.GROUP_ID_CONFIG, "gh399"); > configs.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, > StringDeserializer.class); > configs.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, > StringDeserializer.class); > KafkaConsumer<String, String> consumer = new KafkaConsumer<>(configs); > consumer.assign(Collections.singletonList(new TopicPartition("foo", > 0))); > while (true) { > ConsumerRecords<String, String> records = consumer.poll(1000); > System.out.println(records.count()); > } > {code} > This works all fine, until i shut down the broker. > If i do so, it causes a 100% CPU-load of my application. > After starting the broker again the usage decreases back to a normal level. > It would be very nice if you could help me! > Thanks, > Sebastian > Spring-Kafka: 2.0.0.M3 > Kafka: 0.10.2.0 > JDK: 1.8.0_121 -- This message was sent by Atlassian JIRA (v6.4.14#64029)