qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-845015561
Awesome it works - Thank you and now flowing the structure of camel-k.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-845004443
Argh - I see and this is training on camel k for me..lol
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-844996633
kafka-not-secured-sink.kamelet.yaml
```
apiVersion: camel.apache.org/v1alpha1
kind: Kamelet
metadata:
name: kafka-not-secured-sink
annotations:
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-844996048
http-sink.kamelet.yaml
```
apiVersion: camel.apache.org/v1alpha1
kind: Kamelet
metadata:
name: http-sink-kamelet
annotations:
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-844993984
flow-binding.yaml
```
apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
name: timer-http-kafka
spec:
source:
ref:
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-844964385
After installing :
Install camel-k on the kafka namespace
kamel install -n kafka
Run the following commands
kubectl apply -f
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-80749
Modified code
```
apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
name: timer-http-kafka
spec:
source:
ref:
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-844308206
Here's the code..
```
apiVersion: camel.apache.org/v1alpha1
kind: Kamelet
metadata:
name: http-sink
annotations:
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-844196047
1] 2021-05-19 15:01:13,992 ERROR [org.apa.cam.qua.mai.CamelMainRuntime]
(main) Failed to start application:
org.snakeyaml.engine.v2.exceptions.YamlEngineException:
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-844185525
ERROR [org.apa.cam.qua.mai.CamelMainRuntime] (main) Failed to start
application
```
apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-843971235
Am I on the right track? - WIP
```
apiVersion: camel.apache.org/v1alpha1
kind: Kamelet
metadata:
name: http-sink
annotations:
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-843469607
Am trying to get this authentication HTTPS URL to work, but am unsure if am
using the correct properties for username and password.
Sample fake REST API endpoint:
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-843152321
Thank you - Is there anything I need to config to make it in production to a
real REST API endpoint?
--
This is an automated message from the Apache Git Service.
To
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-843144656
It worked, so the instructions it to install in namespace : kafka
1. kamel install -n kafka
2. install kafka-not-secured-sink.yaml
3. install
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-843047808
last part
```
% kubectl -n kafka run kafka-consumer -ti
--image=quay.io/strimzi/kafka:0.23.0-kafka-2.8.0 --rm=true --restart=Never --
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-843046868
Reinstalled minikube and awaiting logs...
```
% kubectl apply -f namespace.yaml
namespace/kafka created
% helm install strimzi
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-843034815
Reinstalled minikube but issue here
```
~ % minikube addons enable registry
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-842995539
```
2021-05-18T09:05:40.385454950Z
{"level":"info","ts":1621328740.3851337,"logger":"camel-k.controller.kameletbinding","msg":"Invoking
action
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-842992923
It seems that the flow-binding.yaml is not running
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-842977641
Am a newbie to camel,
Update:
```
kubectl -n kafka run kafka-consumer -ti
--image=quay.io/strimzi/kafka:0.23.0-kafka-2.8.0 --rm=true --restart=Never --
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-842538419
I'll test it again tomorrow,but what does kemel install -n kafka cmd do? Nb
typo on the cmd
--
This is an automated message from the Apache Git Service.
To respond
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841831948
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-84247
I've followed the guide and got this issue from camel-k-operator in k8s.
Any ideas?
Error msg :
```
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841831948
Please update me on the progress?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841222715
no problem .. just the general task
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841221713
Thank you and also please can you include API endpoint that requires
username and password or tokens
--
This is an automated message from the Apache Git Service.
To
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841216290
Yes Please
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841213566
Please can you create a sample REST endpoint
http://api.open-notify.org/astros.json into kafka bootstrapServers:
my-cluster-kafka-bootstrap:9092
--
This is an
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841210542
So I'm confused here, so I only need Apache Camel K as a producer into Kafka?
--
This is an automated message from the Apache Git Service.
To respond to the message,
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841205177
Yes - REST endpoint http://api.open-notify.org/astros.json into Kafka
cluster
--
This is an automated message from the Apache Git Service.
To respond to the
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841198913
Sorry - I'll explain the project is to data ingress from REST API into
Kafka (strimzi) in k8s.
Producer API > Kafka connector > Kafka cluster > customers (Spark)
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841193478
Therefore, I should use
[camel-timer-kafka-connector](https://camel.apache.org/camel-kafka-connector/latest/connectors/camel-timer-kafka-source-connector.html)
with
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841190298
Argh - Please which Kafka connector will do the REST API source into Kafka
connect?
--
This is an automated message from the Apache Git Service.
To respond to
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841183902
I followed the doc from strimzi
https://strimzi.io/blog/2021/03/29/connector-build/
--
This is an automated message from the Apache Git Service.
To respond to the
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841095625
After deploying strimzi Kafka connect cluster then deploy kafka connector
kubectl apply -f kafka-connector-rest-source.yaml
--
This is an automated message from
qafro1 commented on issue #1171:
URL:
https://github.com/apache/camel-kafka-connector/issues/1171#issuecomment-841079022
Please wherein the kind: KafkaConnector script do I add the components in
the connector unzipped and can you show me a sample in the k8s script above?
--
This is an
36 matches
Mail list logo
