an and automatic
recovery. Has this idea been considered before? Does it have fatal flaws?
Thanks,
--
Jack Foy
c/main/scala/com/whitepages/kafka/consumer/Connector.scala:21:
missing arguments for method commitOffsets in trait ConsumerConnector;
[error] follow this method with `_' if you want to treat it as a partially
applied function
[error] connector.commitOffsets
[error]
On Oct 29, 2014, at 3:03 PM, Jack Foy wrote:
> On Oct 29, 2014, at 1:46 PM, Neha Narkhede wrote:
>> Which version of Scala did you use for Kafka 0.8.2-beta?
>
> The problem reproduces under both Scala 2.10.4 and Scala 2.11.2.
Sorry, to be clearer:
I am using SBT wit
On Oct 29, 2014, at 1:46 PM, Neha Narkhede wrote:
> Which version of Scala did you use for Kafka 0.8.2-beta?
The problem reproduces under both Scala 2.10.4 and Scala 2.11.2.
--
Jack Foy
error] (compile:compile) Compilation failed
The following change resolved the error:
-connector.commitOffsets
+connector.commitOffsets()
Should we expect compilation-breaking changes moving from 0.8.1.1 to
0.8.2-beta?
--
Jack Foy
and we’ll investigate
further.
--
Jack Foy
utdownableThread.run(ShutdownableThread.scala:51)
--
Jack Foy mailto:j...@whitepages.com>>
)
writeChannel = channel
readChannel = Channels.newChannel(channel.socket().getInputStream)
Is the next step to create a JIRA with this information? Thanks.
--
Jack Foy
