Tag: Apache Kafka
apache kafka – KafkaStreams metrics, records processed per stream/extracting offset for each stream in topology
I’m using org.apache.kafka.streams.KafkaStreams and for example my topology looks this: StreamsBuilder builder = new StreamsBuilder(); builder.stream(“input-topic1”) .mapValues((readOnlyKey, value) -> value.toUpperCase()) .to(“output-topic1”); builder.stream(“input-topic2”) .mapValues((readOnlyKey, value) -> value.toUpperCase()) .to(“output-topic2”); Every two minutes…
apache kafka – java.lang.UnsupportedOperationException: getPosition is not implemented by this StateStore
NAjava.lang.UnsupportedOperationException: getPosition is not implemented by this StateStore at org.apache.kafka.streams.processor.StateStore.getPosition(StateStore.java:165) at org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.log(ChangeLoggingKeyValueBytesStore.java:142) at org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.put(ChangeLoggingKeyValueBytesStore.java:79) at org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.put(ChangeLoggingKeyValueBytesStore.java:33) Please let us know the alternative for this method in Kafka Read more here:…
apache kafka – Least permission set to be able to use (nodejs) kafkajs’s AdminAPI.listTopics()
The popular NodeJS Kafka client, kafkajs, has a method on the admin client part of it to list all the topics in the broker. kafka.js.org/docs/admin However this method returns an…