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