You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Currently it is broken if you want to use it within your KafkaStreams app they way shown in "lenses-topology-example" repo.
The issue is related to io.lenses.topology.client.kafka.metrics.TopologyKafkaStreamsClientSupplier which still implements "getAdminClient" method instead of "getAdmin". See KIP-476: Add Java AdminClient Interface (deprecation of getAdminClient) and KAFKA-12630 (Removal of deprecated getAdminClient API in Kafka Version 3.0.0)
The fix would be quite easy I think (see below) and I was about to do it and hand it in via pull request, but looking at the versions of the libraries that this depends on, etc. I first would like to ask the question: Do you guys still plan support this library (as I said: still mentioned in latest Lenses docs) or is this thing dead and will stay dead?
Thanks in advance!
Warm regards,
Mirko Rüther
package io.lenses.topology.client.kafka.metrics;
[...]
import org.apache.kafka.clients.admin.Admin;
[...]
public class TopologyKafkaStreamsClientSupplier implements KafkaClientSupplier {
[...]
@Override
public Admin getAdmin(final Map<String, Object> config) {
return Admin.create(config);
}
[...]
}
Log:
Exception in thread "main" java.lang.UnsupportedOperationException: Implementations of KafkaClientSupplier should implement the getAdmin() method.
at org.apache.kafka.streams.KafkaClientSupplier.getAdmin(KafkaClientSupplier.java:40)
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:901)
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:865)
at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:835)
at com.example.MyStreamsApp.main(MyStreamsApp.java:xyz)
The text was updated successfully, but these errors were encountered:
Hello Lenses team,
this library seems to not haven gotten much attention in the past few years, although it is still being mentioned in your latest docs here https://docs.lenses.io/5.5/guides/data-applications-integrations/external-apps/#register-via-jvm-client
Currently it is broken if you want to use it within your KafkaStreams app they way shown in "lenses-topology-example" repo.
The issue is related to io.lenses.topology.client.kafka.metrics.TopologyKafkaStreamsClientSupplier which still implements "getAdminClient" method instead of "getAdmin". See KIP-476: Add Java AdminClient Interface (deprecation of getAdminClient) and KAFKA-12630 (Removal of deprecated getAdminClient API in Kafka Version 3.0.0)
The fix would be quite easy I think (see below) and I was about to do it and hand it in via pull request, but looking at the versions of the libraries that this depends on, etc. I first would like to ask the question: Do you guys still plan support this library (as I said: still mentioned in latest Lenses docs) or is this thing dead and will stay dead?
Thanks in advance!
Warm regards,
Mirko Rüther
Log:
The text was updated successfully, but these errors were encountered: