eolivelli commented on code in PR #20721:
URL: https://github.com/apache/pulsar/pull/20721#discussion_r1265041142
##########
pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java:
##########
@@ -274,26 +274,27 @@ public Map<String, String> getProperties(){
return properties;
}
}
- protected static class KeyValueKafkaRecord<V> extends KafkaRecord
implements KVRecord<Object, Object> {
- private final Schema<Object> keySchema;
- private final Schema<Object> valueSchema;
+ protected static class KeyValueKafkaRecord<K, W> extends KafkaRecord
implements KVRecord<K, W> {
Review Comment:
It is not possible to change it, in the past I tried by it has some
consequences I can't remember well
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
