Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Errors publishing and subscribing #153

Open
sparques opened this issue Dec 19, 2018 · 0 comments
Open

Errors publishing and subscribing #153

sparques opened this issue Dec 19, 2018 · 0 comments

Comments

@sparques
Copy link

Using both kafkacat and Sarama, I get errors both trying to subscribe to a topic and trying to publish.

(Topic was created)

mhiles@ln-mhiles > echo test | kafkacat -P -b localhost:9092 -c 1 -t auto-alert-raw
%3|1545247547.398|PROTOERR|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Protocol parse failure at 31/77 (rd_kafka_parse_Metadata:299) (incorrect broker.version.fallback?)
%3|1545247547.398|PROTOERR|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: 65536 topics: tmpabuf memory shortage
%3|1545247548.287|PROTOERR|rdkafka#producer-1| [thrd:main]: localhost:9092/bootstrap: Protocol parse failure at 31/77 (rd_kafka_parse_Metadata:299) (incorrect broker.version.fallback?)

More or less the same story for consuming with kafkacat.

With sarama trying to publish I get this error:

kafka: insufficient data to decode packet, more bytes expected

Does jocko support compression? We're using

config.Producer.Compression = sarama.CompressionSnappy

Although I just tried disabling it and still see the same error message.

Trying to subscribe to a topic, I get this error:

kafka server: Unexpected (unknown?) server error.

We use kafka for prod and I was really hoping I could get jocko working for dev/testing purposes.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant