kafka
kafka copied to clipboard
a0x8o
A high-throughput, distributed, publish-subscribe messaging system
I am getting below exceptions when I am doing put and delete operations of state store. `Ajava.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.delete(ChangeLoggingKeyValueBytesStore.java:110) ...
Bumps commons-net from 3.6 to 3.9.0. [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Why do we always create an admin client with the same "connector-dlq-adminclient-" id? https://github.com/a0x8o/kafka/blob/54eff6af115ee647f60129f2ce6a044cb17215d0/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java#L958 For all other cases, a postfix is added.  Because of this I get "Error registering...
