-
Notifications
You must be signed in to change notification settings - Fork 64
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
Making key and value serdes configurable for enabling JSON (de)serialization #99
Conversation
This reverts commit 8c0f868.
…d deserializer.encoding configs for use within String Serde
e00b1b9
to
f0f6619
Compare
:enable-idempotence false | ||
:value-serializer "org.apache.kafka.common.serialization.StringSerializer" | ||
:key-serializer "org.apache.kafka.common.serialization.StringSerializer"}} | ||
:with-key-val-serdes {:application-id "test" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
why have you added a separate topic-entity
for this. Why not mock config in the test and add or remove values there? This is causing unnecessary repitition in config of this file.
:enable-idempotence false | ||
:value-serializer "org.apache.kafka.common.serialization.StringSerializer" | ||
:key-serializer "org.apache.kafka.common.serialization.StringSerializer"}} | ||
:with-key-val-serdes {:application-id "test" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
same here
"This namespace defines middleware methods for parsing JSON strings. | ||
Please see [Ziggurat Middleware](https://github.com/gojek/ziggurat#middleware-in-ziggurat) for more details. | ||
" | ||
(:require [cheshire.core :refer :all] |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
please use namespaced function names instead of :refer :all
https://github.com/bbatsov/clojure-style-guide#prefer-require-over-use
Reverted the earlier commit where byte array message was converted to String before parsing as JSON
Changed streams.clj to accept any serde. Earlier, byte array was hard-coded.