forklift

forklift copied to clipboard

Feature/use reader schema for specific records

1

The KafkaAvroDeserializer uses the writer schema retrieved from the incoming message to deserialize messages into GenericRecords. This leads to default values in a newer Reader schema being ignored. This PR...

AFrieze

Kafka Connector: Consumer Topic + Grouped Topic Support

2

#### Changes: - Index `KafkaController` instances based on both topic name and the chosen groupId for a topic this way, each different `GroupedTopicSource`s gets it's own underlying `KafkaConsumer` - If...

Kuroshii

- Add the required system implementation. Next up tests to confirm th…

1

…is works as expected.

dcshock

Scenario: 1) On the producer side, a null value is associated with the key "foo" and sent -> message.put("foo", null); 2) On the consumer side, when the value is read...

ghost

Annotation Scanning for Classes that have SubClasses

2

The reflections library isn't doing a good job of scanning annotations when lambdas are used in consumers because of the way the jdk builds them into subclasses. We'll need to...

dcshock

Every process step should either be handled, or produce a sensible error/warning to a log somewhere, instead of failing quietly.

jgsofi

We should probably not allow a consumer that does nothing other than consume a queue to be a valid consumer.

applitect

dcshock