[
https://issues.apache.org/jira/browse/CAMEL-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17164469#comment-17164469
]
SAILOKESH DIVI commented on CAMEL-15320:
----------------------------------------
[~omarsmak] the rote comes up successfully but the subscriber is not able to
talk to pubsub from kubernetes and the grpc errors from the subscribers are
attached to the Jira
As the GooglePubsubConnectionFactory is removed how is the connection handled
to pubsub
1) Will this support workload
identity([https://cloud.google.com/kubernetes-engine/docs/how-to/workload-identity)]
when camel running in kubernetes
Environment we have
1) Kubernetes Pod running camel consuming from Pubsub
2) Workload identity enabled so we don't need the GOOGLE_APP_CREDENTIALS
3) Camel wakes up with no issue
4) When trying to consume messages from pubsub we are seeing grpc errors
[Channel<1>: (<topicName>?maxMessagesPerPoll=10&concurrentConsumers=1)] Failed
to resolve name. status=Status{code=UNAVAILABLE, description=Unable to resolve
host <topicName>, cause=java.lang.RuntimeException:
java.net.UnknownHostException: <topicName>: Name or service not known at
io.grpc.internal.DnsNameResolver.resolveAll(DnsNameResolver.java:436) at
io.grpc.internal.DnsNameResolver$Resolve.resolveInternal(DnsNameResolver.java:272)
at io.grpc.internal.DnsNameResolver$Resolve.run(DnsNameResolver.java:228) at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748) Caused by:
java.net.UnknownHostException: <topicName>: Name or service not known at
java.net.Inet4AddressImpl.lookupAllHostAddr(Native Method) at
java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:929) at
java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1324) at
java.net.InetAddress.getAllByName0(InetAddress.java:1277) at
java.net.InetAddress.getAllByName(InetAddress.java:1193) at
java.net.InetAddress.getAllByName(InetAddress.java:1127) at
io.grpc.internal.DnsNameResolver$JdkAddressResolver.resolveAddress(DnsNameResolver.java:646)
at io.grpc.internal.DnsNameResolver.resolveAll(DnsNameResolver.java:404) ... 5
more
*The same configuration works till 3.1.0 with workload identity*
> grpc errors on camel-google-pubsub with apache camel 3.2.0 or higher
> ---------------------------------------------------------------------
>
> Key: CAMEL-15320
> URL: https://issues.apache.org/jira/browse/CAMEL-15320
> Project: Camel
> Issue Type: Bug
> Components: camel-google-pubsub
> Affects Versions: 3.2.0
> Reporter: SAILOKESH DIVI
> Priority: Minor
>
> 1) The current camel examples utilize GooglePubsubConnectionFactory to
> connect to pubsub till 3.1.0
>
> [https://github.com/apache/camel/blob/camel-3.1.0/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConnectionFactory.java]
>
> This has been removed from camel 3.2 and above and camel can't connect to
> pubsub with grpc errors
>
>
> WARNING: [Channel<1>:
> (<topicName>?maxMessagesPerPoll=10&concurrentConsumers=1)] Failed to resolve
> name. status=Status{code=UNAVAILABLE, description=Unable to resolve host
> <topicName>, cause=java.lang.RuntimeException: java.net.UnknownHostException:
> <topicName>: Name or service not known at
> io.grpc.internal.DnsNameResolver.resolveAll(DnsNameResolver.java:436) at
> io.grpc.internal.DnsNameResolver$Resolve.resolveInternal(DnsNameResolver.java:272)
> at io.grpc.internal.DnsNameResolver$Resolve.run(DnsNameResolver.java:228) at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748) Caused by:
> java.net.UnknownHostException: <topicName>: Name or service not known at
> java.net.Inet4AddressImpl.lookupAllHostAddr(Native Method) at
> java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:929) at
> java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1324) at
> java.net.InetAddress.getAllByName0(InetAddress.java:1277) at
> java.net.InetAddress.getAllByName(InetAddress.java:1193) at
> java.net.InetAddress.getAllByName(InetAddress.java:1127) at
> io.grpc.internal.DnsNameResolver$JdkAddressResolver.resolveAddress(DnsNameResolver.java:646)
> at io.grpc.internal.DnsNameResolver.resolveAll(DnsNameResolver.java:404) ...
> 5 more
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
