Meng Yan
Meng Yan
The pods created by the `KafkaConnect` can't start, when I followed the [document](https://camel.apache.org/camel-kafka-connector/next/user-guide/getting-started/try-it-out-on-kubernetes.html) to create a `KafkaConnect` to backup/sink the Kafka data to aws s3. I'm wondering if there other...
Signed-off-by: myan Adding the Kafka binding with https://github.com/confluentinc/confluent-kafka-go. This implementation will support the following features compared to the [sarama](https://github.com/IBM/sarama) binding. - The binding provides the ability to submit offset asynchronously....
The current MQTT protocol is just a basic implementation. Since the network link between the MQTT broker and the client might drop, we need to detect it and re-establish the...
**There is a scenario base on Kafka protocol binding and I'm not sure how to use the sdk to achieve it:** When the cloudevent client receives an event, it returns...
Given the popularity of this repos: https://github.com/confluentinc/confluent-kafka-go, Are we also considering integrating it? We now have the implementation of [sarama](https://github.com/Shopify/sarama), but there are still many people who are optimistic about...
Fixes: https://github.com/apache/apisix/issues/10412 Changes: Add the blog for proxy the Kafka cluster with apisix Screenshots of the change:
### Issue description It seems we can't get the certs, `curl --cert file1.crt --cacert file2.crt`, from the [request](https://pkg.go.dev/github.com/apache/[email protected]/pkg/http#Request) of the default plugin. In this case, we can only load the...
Description =========== I'm running a service with kafka.Consumer poll message from brokers. But as time goes on, the `kafka._Cfunc_GoBytes (inline)` takes up more and more memory resources How to reproduce...
Description =========== I follow the samples in the repository to create a consumer. But I wonder why we need the [default case](https://github.com/confluentinc/confluent-kafka-go/blob/f1230c0e9dd4b038986ecf26a901e945ec71ca23/examples/consumer_example/consumer_example.go#L117-L118) here? Perhaps we don't need `default` at all?...