Artem Bilan

See this one as an alternative solution: https://github.com/openzipkin/brave/blob/2ef59ea0e687d51e445bb5144c27e373fa73b7d7/instrumentation/kafka-clients/src/main/java/brave/kafka/clients/TracingProducer.java. It feels like a dedicated library as a `kafka-micrometer` should emerge instead where an `Observation` wrapping and handling can be implemented down...

Sounds legit, @marcingrzejszczak . 👍

I think we will keep this one as a `documentation` type to mention in the future how to instrument Kafka Streams with an observability when it is ready on a...

Well, that's really the point. Our unit test has this piece of code: ``` template.execute(session -> { session.mkdir("/foo/"); return session.mkdir("/foo/bar/"); }); ``` That `session` is a wrapper around `SftpClient`. According...

Even if you say that trailing slash is not legit anymore, why just don't return a normalized path from `RootedFileSystemProvider.resolveLocalPath()` as it was before?

Hi here! Any chances to have some sample how to configure `SshClient` for SOCKS forwarding and how to use that feature respectively ? BTW, it looks like you don't need...

Hm, but this [sample](https://github.com/ankitkatiyar91/java-framework-examples/blob/master/java-tunneling/src/main/java/mina/TunnelMina.java) does something on the matter, although it is not clear how to leverage that for our `SftpClient` usage then: ``` sftpClient = SftpClientFactory.instance() .createSftpClient(initClientSession(), this.sftpVersionSelector); ......

Since `spring_json_header_types` is a Spring for Apache Kafka feature, then I assume that you use Kafka Binder. With new Observation API we do populate those headers into the `ProducerRecord` already...

So, how that turned out Spring Integration is involved here? Why doesn't regular Spring for Apache Kafka `KafkaRecordReceiverContext` do the trick to re-instate an observation on the consumer side? I...

However I agree with you that Spring Integration should be flexible enough to support raw `byte[]` for those headers as well. What I want is to find some workaround for...