kafka-proxy
kafka-proxy copied to clipboard
grepplabs
Proxy connections to Kafka cluster. Connect through SOCKS Proxy, HTTP Proxy or to cluster running in Kubernetes.
Hello, I have an issue while using kafka-proxy : ``` bash [Producer clientId=geco-1] Received invalid metadata error in produce request on partition private_dkt_out_listener_kafka_geco_v1-2 due to org.apache.kafka.common.errors.NotLeaderOrFollowerException: For requests intended only...
We have a requirement for KafkaAvroDeserializer, the port of the schema.registry URL is different from the bootstrap IPs, I was looking into a proxy option and wondered if such a...
Hi, We're trying to get Kafka Clients to consume and produce through HTTP, and I'm trying to figure out how to integrate this proxy into our project. What is the...
Hi, I am getting this when a producer contacts MSK through kafka-proxy with TLS. `INFO[2019-12-08T10:34:11Z] Reading data from local connection on 10.20.6.169:9092 from 10.20.12.42:40272 (b-1.msk-a.uv35cd.c3.kafka.eu-west-1.amazonaws.com:9094) had error: tls: received unexpected...
I keep getting "had error: api key -10495 is invalid" when I try to proxy a Kafka cluster with SASL. Is this because the Kafka broker version is too old?...
Any plans to support MSK IAM capabilities? Details of Java implementation in --> https://github.com/aws/aws-msk-iam-auth I'll take a stab at submitting a PR for this but need some guidance. Could you...
Looks like it's not possible for a client behind kafka-proxy or kafka-proxy itself to authenticate themselves to Kafka brokers with Kerberos credentials? How difficult could it be to support this...
Question? Is it possible to access this example externally via a service (exposed via LoadBalancer) ? https://github.com/grepplabs/kafka-proxy#connect-to-kafka-running-in-kubernetes-example-kafka-proxy-runs-in-cluster This example works via the kubectl port-forward command but when we try to...
Hi, I'm evaluating/prototyping this project for internal use at the company I work for and I have made a couple of updates that might be of interest: First off, switching...
Hi, I am trying to use the kafka-proxy as a way to do cross-[VPC](https://aws.amazon.com/vpc/?vpc-blogs.sort-by=item.additionalFields.createdDate&vpc-blogs.sort-order=desc) access for [AWS MSK](https://aws.amazon.com/msk/). First of all, I am trying to set up the proxy within...
