[GitHub] [camel-kafka-connector] duanasq commented on issue #1268: java.lang.NullPointerException in kinesis sink connector if headers not present

[GitBox]

duanasq commented on issue #1268:
URL: 
https://github.com/apache/camel-kafka-connector/issues/1268#issuecomment-942184895






-- 
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: commits-unsubscr...@camel.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] duanasq commented on issue #1268: java.lang.NullPointerException in kinesis sink connector if headers not present

[GitBox]

duanasq commented on issue #1268:
URL: 
https://github.com/apache/camel-kafka-connector/issues/1268#issuecomment-942186560


   I think it's worth mentioning that in the documentation for the camel 
kinesis sink connector because it feels like it's necessary if you want to use 
it. I would be happy to submit a PR to the doc.


-- 
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: commits-unsubscr...@camel.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] duanasq commented on issue #1268: java.lang.NullPointerException in kinesis sink connector if headers not present

[GitBox]

duanasq commented on issue #1268:
URL: 
https://github.com/apache/camel-kafka-connector/issues/1268#issuecomment-942184895


   That worked, thanks. I used an apply function like this:
   
   ```
 @Override
 public R apply(R record) {
   var headerValue = "partition-" + record.kafkaPartition();
   var newHeaders = 
record.headers().duplicate().add("CamelHeader.CamelAwsKinesisPartitionKey", 
headerValue,
   ConnectSchema.STRING_SCHEMA);
   
   return record.newRecord(record.topic(), record.kafkaPartition(), 
record.keySchema(),
   record.key(), record.valueSchema(), record.value(), 
record.timestamp(), newHeaders);
 }
 ```


-- 
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: commits-unsubscr...@camel.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [camel-kafka-connector] duanasq commented on issue #1268: java.lang.NullPointerException in kinesis sink connector if headers not present

[GitBox]

duanasq commented on issue #1268:
URL: 
https://github.com/apache/camel-kafka-connector/issues/1268#issuecomment-939731187


   ok [there is advice 
here](https://github.com/apache/camel-kafka-connector/pull/1262#issuecomment-93367)
 to create an SMT, which is actually [part of the Connect 
framework](https://docs.confluent.io/platform/current/connect/transforms/overview.html),
 not Camel.


-- 
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: commits-unsubscr...@camel.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org