Skip to content

Cannot consume from kafka broker 2.0.0 #83

@vmaurin

Description

@vmaurin

Hello
I have tried to consume messages produced in a broker 2.0.0, with console producer same version with kt and it fails
Enabling the verbose mode, I got this output

2018/09/03 16:14:42 Connected to broker at xxxx:9092 (registered as #0)
2018/09/03 16:14:42 consumer/broker/0 added subscription to test/2
2018/09/03 16:14:42 consumer/broker/0 disconnecting due to error processing FetchRequest: kafka: error decoding packet: CRC didn't match
2018/09/03 16:14:42 Closed connection to broker xxxx:9092
2018/09/03 16:14:42 kafka: error while consuming test/2: kafka: error decoding packet: CRC didn't match

Something seems incompatible with the protocol

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions