kafkaproxy issues

Results 10 kafkaproxy issues

Sort by recently updated

Is it possible to use this proxy code to intercept messages?

Hi, I would like to capture what is consumed and published from an application, and I want the application to go through a Kafka proxy. Does this source code (without...

osoykan

msk connection not working via SASL_SSL

Hello, I am trying to use the proxy in-front of SASL_SSL MSK brokers. For some reason I am getting: terminated during authentication. This may happen due to any of the...

meran

Bump org.apache.kafka:kafka-clients from 3.4.0 to 3.5.0

Bumps org.apache.kafka:kafka-clients from 3.4.0 to 3.5.0. [![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=org.apache.kafka:kafka-clients&package-manager=gradle&previous-version=3.4.0&new-version=3.5.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]

type/dependency

Bump ch.qos.logback:logback-classic from 1.4.1 to 1.4.8

Bumps [ch.qos.logback:logback-classic](https://github.com/qos-ch/logback) from 1.4.1 to 1.4.8. Commits 60f4910 prepare release 1.4.8 ca7fbc7 link logbackMDCAdapter in LoggerContext, fixes LOGBACK-1742 9e833ec ongoing work on JsonEncoder LOGBACK-1734 97e5175 ongoing work on JsonEnconder f7ae802...

dependabot[bot]

type/dependency

Bump org.testcontainers:kafka from 1.17.6 to 1.18.3

Bumps [org.testcontainers:kafka](https://github.com/testcontainers/testcontainers-java) from 1.17.6 to 1.18.3. Release notes Sourced from org.testcontainers:kafka's releases. 1.18.3 Testcontainers for Java 1.18.2 introduced new strategies to detect the docker.sock. There was an issue reported, see...

dependabot[bot]

type/dependency

Support MSK IAM Auth

Would like to request support for MSK IAM Auth --> https://github.com/aws/aws-msk-iam-auth I was trying to look through the code but it was not clear if the above is supported; did...

leowmjw

Kafka proxy getting "Failed to initialize a channel" error.

I am trying to run a kafka cluster(v3.0.0) with 3 kafka replicas and 1 zookeeper. On top it we are using the Kafka proxy to setup ingress to allow remote...

rashiga