Description
In 0.8.1.x, ConsumerConnector has the following api:
def commitOffsets
This is changed to the following in 0.8.2 and breaks compatibility
def commitOffsets(retryOnFailure: Boolean = true)
In 0.8.1.x, ConsumerConnector has the following api:
def commitOffsets
This is changed to the following in 0.8.2 and breaks compatibility
def commitOffsets(retryOnFailure: Boolean = true)