使用Transaction记录kafka的org.apache.kafka.clients.consumer.KafkaConsumer#poll(long)方法，但是这个方法会每秒调用一次，有没有一种方法，在拉取有结果时才记录Transaction.否则丢弃掉

CatTransaction t = Cat.newTransaction("kafka", "poll");
try {
	ConsumerRecords consumerRecords = poll(1000);
	if (consumerRecords == null || consumerRecords.count() == 0) {
		t.discard();  // 丢弃
		return;
	}
	t.complete();
} catch (Exception e) {
	t.setStatus(e);
	t.complete();
	logger.error("", e);
}