camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jay mann (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (CAMEL-10087) camel-kafka does not work in OSGI container
Date Fri, 24 Jun 2016 16:16:16 GMT

    [ https://issues.apache.org/jira/browse/CAMEL-10087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15348495#comment-15348495
] 

Jay mann commented on CAMEL-10087:
----------------------------------

I'm building camel-karaf from lastest 2.17.x -It is barfing on the serializer:

org.apache.camel.RuntimeCamelException: org.apache.kafka.common.config.ConfigException: Invalid
value org.apache.kafka.common.serialization.StringDeserializer f
or configuration value.deserializer: Class org.apache.kafka.common.serialization.StringDeserializer
could not be found.
        at org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1690)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:138)[98:org.apache.camel.camel-spring:2.17.1]
        at org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:340)[98:org.apache.camel.camel-spring:2.17.1]
        at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:96)[107:org.apache.servicem
ix.bundles.spring-context:3.2.14.RELEASE_1]
        at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:334)[107:org.apache.servicemix.bundles.sp
ring-context:3.2.14.RELEASE_1]
        at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:950)[107:org.apache.servicemix.bundles.s
pring-context:3.2.14.RELEASE_1]
        at org.springframework.osgi.context.support.AbstractOsgiBundleApplicationContext.finishRefresh(AbstractOsgiBundleApplicationContext.java:235)[112:org.sp
ringframework.osgi.core:1.2.1]
        at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext$4.run(AbstractDelegatedExecutionApplicationContext.java:358)[11
2:org.springframework.osgi.core:1.2.1]
        at org.springframework.osgi.util.internal.PrivilegedUtils.executeWithCustomTCCL(PrivilegedUtils.java:85)[112:org.springframework.osgi.core:1.2.1]
        at org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.completeRefresh(AbstractDelegatedExecutionApplicationContext.ja
va:320)[112:org.springframework.osgi.core:1.2.1]
        at org.springframework.osgi.extender.internal.dependencies.startup.DependencyWaiterApplicationContextExecutor$CompleteRefreshTask.run(DependencyWaiterAp
plicationContextExecutor.java:132)[113:org.springframework.osgi.extender:1.2.1]
        at java.lang.Thread.run(Thread.java:745)[:1.8.0_92-internal]
Caused by: org.apache.kafka.common.config.ConfigException: Invalid value org.apache.kafka.common.serialization.StringDeserializer
for configuration value.deseri
alizer: Class org.apache.kafka.common.serialization.StringDeserializer could not be found.
        at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:255)[149:wrap_mvn_org.apache.kafka_kafka-clients_0.9.0.1:0.0.0]
        at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:145)[149:wrap_mvn_org.apache.kafka_kafka-clients_0.9.0.1:0.0.0]
        at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:49)[149:wrap_mvn_org.apache.kafka_kafka-clients_0.9.0.1:0.0.0]
        at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:56)[149:wrap_mvn_org.apache.kafka_kafka-clients_0.9.0.1:0.0.0]
        at org.apache.kafka.clients.consumer.ConsumerConfig.<init>(ConsumerConfig.java:336)[149:wrap_mvn_org.apache.kafka_kafka-clients_0.9.0.1:0.0.0]
        at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:542)[149:wrap_mvn_org.apache.kafka_kafka-clients_0.9.0.1:0.0.0]
        at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:524)[149:wrap_mvn_org.apache.kafka_kafka-clients_0.9.0.1:0.0.0]
        at org.apache.camel.component.kafka.KafkaConsumer$KafkaFetchRecords.<init>(KafkaConsumer.java:97)[150:org.apache.camel.camel-kafka:2.17.2.SNAPSHOT]
        at org.apache.camel.component.kafka.KafkaConsumer.doStart(KafkaConsumer.java:67)[150:org.apache.camel.camel-kafka:2.17.2.SNAPSHOT]
        at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:3269)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRouteConsumers(DefaultCamelContext.java:3563)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.impl.DefaultCamelContext.doStartRouteConsumers(DefaultCamelContext.java:3499)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3429)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:3197)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:3053)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:175)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2848)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2844)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:2867)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:2844)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:2813)[97:org.apache.camel.camel-core:2.17.1]
        at org.apache.camel.spring.SpringCamelContext.maybeStart(SpringCamelContext.java:270)[98:org.apache.camel.camel-spring:2.17.1]
        at org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:136)[98:org.apache.camel.camel-spring:2.17.1]
        ... 10 more
2016-06-24 16:12:11,103 | INFO  | om-component-in] | AbstractCoordinator              | 149
- wrap_mvn_org.apache.kafka_kafka-clients_0.9.0.1 - 0.0.0 | Attempt
to heart beat failed since the group is rebalancing, try to re-join group.
2016-06-24 16:12:11,201 | INFO  | omponent-in-xml] | AbstractCoordinator              | 149
- wrap_mvn_org.apache.kafka_kafka-clients_0.9.0.1 - 0.0.0 | Marking
the coordinator 2147482646 dead.
2016-06-24 16:12:12,356 | INFO  | om-component-in] | AbstractCoordinator              | 149
- wrap_mvn_org.apache.kafka_kafka-clients_0.9.0.1 - 0.0.0 | Attempt
to heart beat failed since the group is rebalancing, try to re-join group.
2016-06-24 16:12:12,453 | INFO  | om-component-in] | AbstractCoordinator              | 149
- wrap_mvn_org.apache.kafka_kafka-clients_0.9.0.1 - 0.0.0 | Attempt
to heart beat failed since the group is rebalancing, try to re-join group.
2016-06-24 16:12:12,468 | INFO  | om-component-in] | AbstractCoordinator              | 149
- wrap_mvn_org.apache.kafka_kafka-clients_0.9.0.1 - 0.0.0 | Attempt
to heart beat failed since the group is rebalancing, try to re-join group.
2016-06-24 16:12:12,569 | INFO  | omponent-in-xml] | AbstractCoordinator              | 149
- wrap_mvn_org.apache.kafka_kafka-clients_0.9.0.1 - 0.0.0 | Attempt

> camel-kafka does not work in OSGI container
> -------------------------------------------
>
>                 Key: CAMEL-10087
>                 URL: https://issues.apache.org/jira/browse/CAMEL-10087
>             Project: Camel
>          Issue Type: Bug
>          Components: camel-kafka
>    Affects Versions: 2.17.1
>            Reporter: Jay mann
>
> Currently this component is broken in OSGI environment due to this:
> https://issues.apache.org/jira/browse/KAFKA-3218
> We can leave it broken until they get their bugs worked out.  Or i can submit a PR with
an intermediate fix that should work, as described in the jira noted above.
> https://github.com/apache/camel/pull/1049



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message