Question
PEGA Upgrade Infinity KAfka Headers are not working
PEGA Upgrade Infinity KAfka Headers are not working
@harshita7040 Please can you provide more context in your question.
What version were you on previously, and what was working at that time?
I see that you logged INC-B40178 (Kafka headers not able to read) on September last year for Pega 8.7.3.
Steps to reproduce
- : Data Set we have kafka headers
- add headers key
- this header messagenot reflecting while browing messages
Solution :
Review the step page data being published to the Kafka topic.
You can explore the option of using the Enable custom processing checkbox. The custom processing class has 2 inputs:
-
message object and header object
-
output is modified messages
In your UseCase, maybe it's better to do Avro deserialization in Custom processing stage. So processing will be like this: you receive an Avro message and header in Custom processing class, deserialize message with Avro, modify message by adding values from Headers argument.
Plan: Can you have a look over the doc and linked docs as well and review the configurations of avro schema:
@harshita7040 Please can you provide more context in your question.
What version were you on previously, and what was working at that time?
I see that you logged INC-B40178 (Kafka headers not able to read) on September last year for Pega 8.7.3.
Steps to reproduce
- : Data Set we have kafka headers
- add headers key
- this header messagenot reflecting while browing messages
Solution :
Review the step page data being published to the Kafka topic.
You can explore the option of using the Enable custom processing checkbox. The custom processing class has 2 inputs:
-
message object and header object
-
output is modified messages
In your UseCase, maybe it's better to do Avro deserialization in Custom processing stage. So processing will be like this: you receive an Avro message and header in Custom processing class, deserialize message with Avro, modify message by adding values from Headers argument.
Plan: Can you have a look over the doc and linked docs as well and review the configurations of avro schema: