KafkaConsumerRequest extends ConsumerRequest { @Override public String operation() { return "receive"; } KafkaConsumerRequest(ConsumerRecord<?, ?> delegate); @Override Kind spanKind(); @Override Object unwrap(); @Override String operation(); @Override String channelKind(); @Override String channelName(); @Nullable @Override String messageId();  }
@Test public void operation() { assertThat(request.operation()).isEqualTo("receive"); }