Add ConsumerProducer application #387
Conversation
...c/test/java/com/bakdata/kafka/consumerproducer/apps/MirrorValueWithAvroConsumerProducer.java
Show resolved
Hide resolved
| */ | ||
| @RequiredArgsConstructor | ||
| @With | ||
| public class SerializerDeserializerConfig implements SerializationConfig { |
There was a problem hiding this comment.
We noticed during implementation of our first ConsumerProducers that perhaps switching the name parts around to DeserializerSerializerConfig makes sense since in the "data flow", input records are deserialized before output records are serialized. WDYT? In case you agree, we should also switch around the args in the constructor below.
There was a problem hiding this comment.
Valid point on the data flow. I don't have a strong opinion, but my slight preference is still SerializerDeserializerConfig just to match the industry-standard SerDe, but I am open to switching it if you feel strongly about switching the naming.
README.md
Outdated
| // your logic | ||
| consumedValue -> consumedValue |
There was a problem hiding this comment.
Perhaps also produce here in the example?
...c/test/java/com/bakdata/kafka/consumerproducer/apps/MirrorValueWithAvroConsumerProducer.java
Show resolved
Hide resolved
|
No description provided.