You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Dima Gutzeit <gu...@maaii.com> on 2012/07/30 07:24:12 UTC

Running kafka with scala 2.10-M*

Dear all,

I am using Kafka with the same project together with Akka, and recently Akka team released a version that depends on Scala 2.10-M5. The problem is that since then I can not use Kafka anymore. I get the following exception when trying to initialize the Kafka consumer:

Caused by: java.lang.NoSuchMethodError: scala.Predef$.augmentString(Ljava/lang/String;)Lscala/collection/immutable/StringOps;
 at kafka.utils.Utils$.getIntInRange(Utils.scala:189)
 at kafka.utils.Utils$.getInt(Utils.scala:174)
 at kafka.consumer.ConsumerConfig.<init>(ConsumerConfig.scala:56)
 at com.maaii.data.model.kafka.KafkaConfigurationManagerImpl.getConsumerConfig(KafkaConfigurationManagerImpl.java:222)
 at com.maaii.data.model.kafka.CacheEvictionHandlerImpl.setUpConsumer(CacheEvictionHandlerImpl.java:108)
 at com.maaii.data.model.kafka.CacheEvictionHandlerImpl.startUp(CacheEvictionHandlerImpl.java:64)

Can anyone suggest a way of building Kafka for scala 2.10 ?

Thanks in advance.

Regards,
Dima Gutzeit.

Re: Running kafka with scala 2.10-M*

Posted by Neha Narkhede <ne...@gmail.com>.
Try changing it after applying that patch.

Thanks,
Neha

On Wed, Aug 1, 2012 at 7:06 PM, Dima Gutzeit <gu...@maaii.com> wrote:
> After the patch of before the patch ?
>
> Without the patch, changing the scala version alone produces the exception
> I mentioned in my initial message.
>
> Dima.
>
>
>
> On 2/8/12 9:51 AM, "Jun Rao" <ju...@gmail.com> wrote:
>
>>For now, you can probably get it working by changing the scala version in
>>project/build.properties
>>
>>Thanks,
>>
>>Jun
>>
>>On Wed, Aug 1, 2012 at 6:42 PM, Dima Gutzeit <gu...@maaii.com> wrote:
>>
>>> Any idea when its due to be complete and when the new sbt/scala will be
>>> supported ?
>>> You see, I am a Java kind of guy and I do not want to learn SBT just for
>>> that, although I can :).
>>>
>>> The patch attached to the case is outdated since was created for 0.7 and
>>> the build files have been changed since then.
>>>
>>> Dima.
>>>
>>>
>>>
>>>
>>>
>>> On 1/8/12 10:57 PM, "Jun Rao" <ju...@gmail.com> wrote:
>>>
>>> >Dima,
>>> >
>>> >This is being tracked in
>>>https://issues.apache.org/jira/browse/KAFKA-134.
>>> >The patch is not complete, but you can probably give it a try.
>>> >
>>> >Thanks,
>>> >
>>> >Jun
>>> >
>>> >On Sun, Jul 29, 2012 at 10:24 PM, Dima Gutzeit <gu...@maaii.com>
>>>wrote:
>>> >
>>> >> Dear all,
>>> >>
>>> >> I am using Kafka with the same project together with Akka, and
>>>recently
>>> >> Akka team released a version that depends on Scala 2.10-M5. The
>>>problem
>>> >>is
>>> >> that since then I can not use Kafka anymore. I get the following
>>> >>exception
>>> >> when trying to initialize the Kafka consumer:
>>> >>
>>> >> Caused by: java.lang.NoSuchMethodError:
>>> >>
>>>
>>>>>scala.Predef$.augmentString(Ljava/lang/String;)Lscala/collection/immuta
>>>>>bl
>>> >>e/StringOps;
>>> >>  at kafka.utils.Utils$.getIntInRange(Utils.scala:189)
>>> >>  at kafka.utils.Utils$.getInt(Utils.scala:174)
>>> >>  at kafka.consumer.ConsumerConfig.<init>(ConsumerConfig.scala:56)
>>> >>  at
>>> >>
>>>
>>>>>com.maaii.data.model.kafka.KafkaConfigurationManagerImpl.getConsumerCon
>>>>>fi
>>> >>g(KafkaConfigurationManagerImpl.java:222)
>>> >>  at
>>> >>
>>>
>>>>>com.maaii.data.model.kafka.CacheEvictionHandlerImpl.setUpConsumer(Cache
>>>>>Ev
>>> >>ictionHandlerImpl.java:108)
>>> >>  at
>>> >>
>>>
>>>>>com.maaii.data.model.kafka.CacheEvictionHandlerImpl.startUp(CacheEvicti
>>>>>on
>>> >>HandlerImpl.java:64)
>>> >>
>>> >> Can anyone suggest a way of building Kafka for scala 2.10 ?
>>> >>
>>> >> Thanks in advance.
>>> >>
>>> >> Regards,
>>> >> Dima Gutzeit.
>>> >>
>>>
>>>
>

Re: Running kafka with scala 2.10-M*

Posted by Dima Gutzeit <gu...@maaii.com>.
After the patch of before the patch ?

Without the patch, changing the scala version alone produces the exception
I mentioned in my initial message.

Dima.



On 2/8/12 9:51 AM, "Jun Rao" <ju...@gmail.com> wrote:

>For now, you can probably get it working by changing the scala version in
>project/build.properties
>
>Thanks,
>
>Jun
>
>On Wed, Aug 1, 2012 at 6:42 PM, Dima Gutzeit <gu...@maaii.com> wrote:
>
>> Any idea when its due to be complete and when the new sbt/scala will be
>> supported ?
>> You see, I am a Java kind of guy and I do not want to learn SBT just for
>> that, although I can :).
>>
>> The patch attached to the case is outdated since was created for 0.7 and
>> the build files have been changed since then.
>>
>> Dima.
>>
>>
>>
>>
>>
>> On 1/8/12 10:57 PM, "Jun Rao" <ju...@gmail.com> wrote:
>>
>> >Dima,
>> >
>> >This is being tracked in
>>https://issues.apache.org/jira/browse/KAFKA-134.
>> >The patch is not complete, but you can probably give it a try.
>> >
>> >Thanks,
>> >
>> >Jun
>> >
>> >On Sun, Jul 29, 2012 at 10:24 PM, Dima Gutzeit <gu...@maaii.com>
>>wrote:
>> >
>> >> Dear all,
>> >>
>> >> I am using Kafka with the same project together with Akka, and
>>recently
>> >> Akka team released a version that depends on Scala 2.10-M5. The
>>problem
>> >>is
>> >> that since then I can not use Kafka anymore. I get the following
>> >>exception
>> >> when trying to initialize the Kafka consumer:
>> >>
>> >> Caused by: java.lang.NoSuchMethodError:
>> >>
>> 
>>>>scala.Predef$.augmentString(Ljava/lang/String;)Lscala/collection/immuta
>>>>bl
>> >>e/StringOps;
>> >>  at kafka.utils.Utils$.getIntInRange(Utils.scala:189)
>> >>  at kafka.utils.Utils$.getInt(Utils.scala:174)
>> >>  at kafka.consumer.ConsumerConfig.<init>(ConsumerConfig.scala:56)
>> >>  at
>> >>
>> 
>>>>com.maaii.data.model.kafka.KafkaConfigurationManagerImpl.getConsumerCon
>>>>fi
>> >>g(KafkaConfigurationManagerImpl.java:222)
>> >>  at
>> >>
>> 
>>>>com.maaii.data.model.kafka.CacheEvictionHandlerImpl.setUpConsumer(Cache
>>>>Ev
>> >>ictionHandlerImpl.java:108)
>> >>  at
>> >>
>> 
>>>>com.maaii.data.model.kafka.CacheEvictionHandlerImpl.startUp(CacheEvicti
>>>>on
>> >>HandlerImpl.java:64)
>> >>
>> >> Can anyone suggest a way of building Kafka for scala 2.10 ?
>> >>
>> >> Thanks in advance.
>> >>
>> >> Regards,
>> >> Dima Gutzeit.
>> >>
>>
>>


Re: Running kafka with scala 2.10-M*

Posted by Jun Rao <ju...@gmail.com>.
For now, you can probably get it working by changing the scala version in
project/build.properties

Thanks,

Jun

On Wed, Aug 1, 2012 at 6:42 PM, Dima Gutzeit <gu...@maaii.com> wrote:

> Any idea when its due to be complete and when the new sbt/scala will be
> supported ?
> You see, I am a Java kind of guy and I do not want to learn SBT just for
> that, although I can :).
>
> The patch attached to the case is outdated since was created for 0.7 and
> the build files have been changed since then.
>
> Dima.
>
>
>
>
>
> On 1/8/12 10:57 PM, "Jun Rao" <ju...@gmail.com> wrote:
>
> >Dima,
> >
> >This is being tracked in https://issues.apache.org/jira/browse/KAFKA-134.
> >The patch is not complete, but you can probably give it a try.
> >
> >Thanks,
> >
> >Jun
> >
> >On Sun, Jul 29, 2012 at 10:24 PM, Dima Gutzeit <gu...@maaii.com> wrote:
> >
> >> Dear all,
> >>
> >> I am using Kafka with the same project together with Akka, and recently
> >> Akka team released a version that depends on Scala 2.10-M5. The problem
> >>is
> >> that since then I can not use Kafka anymore. I get the following
> >>exception
> >> when trying to initialize the Kafka consumer:
> >>
> >> Caused by: java.lang.NoSuchMethodError:
> >>
> >>scala.Predef$.augmentString(Ljava/lang/String;)Lscala/collection/immutabl
> >>e/StringOps;
> >>  at kafka.utils.Utils$.getIntInRange(Utils.scala:189)
> >>  at kafka.utils.Utils$.getInt(Utils.scala:174)
> >>  at kafka.consumer.ConsumerConfig.<init>(ConsumerConfig.scala:56)
> >>  at
> >>
> >>com.maaii.data.model.kafka.KafkaConfigurationManagerImpl.getConsumerConfi
> >>g(KafkaConfigurationManagerImpl.java:222)
> >>  at
> >>
> >>com.maaii.data.model.kafka.CacheEvictionHandlerImpl.setUpConsumer(CacheEv
> >>ictionHandlerImpl.java:108)
> >>  at
> >>
> >>com.maaii.data.model.kafka.CacheEvictionHandlerImpl.startUp(CacheEviction
> >>HandlerImpl.java:64)
> >>
> >> Can anyone suggest a way of building Kafka for scala 2.10 ?
> >>
> >> Thanks in advance.
> >>
> >> Regards,
> >> Dima Gutzeit.
> >>
>
>

Re: Running kafka with scala 2.10-M*

Posted by Dima Gutzeit <gu...@maaii.com>.
Any idea when its due to be complete and when the new sbt/scala will be
supported ?
You see, I am a Java kind of guy and I do not want to learn SBT just for
that, although I can :).

The patch attached to the case is outdated since was created for 0.7 and
the build files have been changed since then.

Dima.
    

 


On 1/8/12 10:57 PM, "Jun Rao" <ju...@gmail.com> wrote:

>Dima,
>
>This is being tracked in https://issues.apache.org/jira/browse/KAFKA-134.
>The patch is not complete, but you can probably give it a try.
>
>Thanks,
>
>Jun
>
>On Sun, Jul 29, 2012 at 10:24 PM, Dima Gutzeit <gu...@maaii.com> wrote:
>
>> Dear all,
>>
>> I am using Kafka with the same project together with Akka, and recently
>> Akka team released a version that depends on Scala 2.10-M5. The problem
>>is
>> that since then I can not use Kafka anymore. I get the following
>>exception
>> when trying to initialize the Kafka consumer:
>>
>> Caused by: java.lang.NoSuchMethodError:
>> 
>>scala.Predef$.augmentString(Ljava/lang/String;)Lscala/collection/immutabl
>>e/StringOps;
>>  at kafka.utils.Utils$.getIntInRange(Utils.scala:189)
>>  at kafka.utils.Utils$.getInt(Utils.scala:174)
>>  at kafka.consumer.ConsumerConfig.<init>(ConsumerConfig.scala:56)
>>  at
>> 
>>com.maaii.data.model.kafka.KafkaConfigurationManagerImpl.getConsumerConfi
>>g(KafkaConfigurationManagerImpl.java:222)
>>  at
>> 
>>com.maaii.data.model.kafka.CacheEvictionHandlerImpl.setUpConsumer(CacheEv
>>ictionHandlerImpl.java:108)
>>  at
>> 
>>com.maaii.data.model.kafka.CacheEvictionHandlerImpl.startUp(CacheEviction
>>HandlerImpl.java:64)
>>
>> Can anyone suggest a way of building Kafka for scala 2.10 ?
>>
>> Thanks in advance.
>>
>> Regards,
>> Dima Gutzeit.
>>


Re: Running kafka with scala 2.10-M*

Posted by Jun Rao <ju...@gmail.com>.
Dima,

This is being tracked in https://issues.apache.org/jira/browse/KAFKA-134.
The patch is not complete, but you can probably give it a try.

Thanks,

Jun

On Sun, Jul 29, 2012 at 10:24 PM, Dima Gutzeit <gu...@maaii.com> wrote:

> Dear all,
>
> I am using Kafka with the same project together with Akka, and recently
> Akka team released a version that depends on Scala 2.10-M5. The problem is
> that since then I can not use Kafka anymore. I get the following exception
> when trying to initialize the Kafka consumer:
>
> Caused by: java.lang.NoSuchMethodError:
> scala.Predef$.augmentString(Ljava/lang/String;)Lscala/collection/immutable/StringOps;
>  at kafka.utils.Utils$.getIntInRange(Utils.scala:189)
>  at kafka.utils.Utils$.getInt(Utils.scala:174)
>  at kafka.consumer.ConsumerConfig.<init>(ConsumerConfig.scala:56)
>  at
> com.maaii.data.model.kafka.KafkaConfigurationManagerImpl.getConsumerConfig(KafkaConfigurationManagerImpl.java:222)
>  at
> com.maaii.data.model.kafka.CacheEvictionHandlerImpl.setUpConsumer(CacheEvictionHandlerImpl.java:108)
>  at
> com.maaii.data.model.kafka.CacheEvictionHandlerImpl.startUp(CacheEvictionHandlerImpl.java:64)
>
> Can anyone suggest a way of building Kafka for scala 2.10 ?
>
> Thanks in advance.
>
> Regards,
> Dima Gutzeit.
>