Skip to main content

Posts

Showing posts with the label Java

Java Senior Engineer Job at leading e-Government software and services provider Dubai United Arab Emirates

Java Senior Engineer Our client is a leading e-Government software and services provider. They are looking for a highly skilled senior Java developer to join the team. In this role, you will become part of a highly qualified and experienced team responsible for the development and operations of a core product and its surrounding application infrastructure. Your responsibilities : Deployment of Java applications using CI/CD pipeline. Scalability, Reliability, Zero downtime, and Operational Efficiency of the developed modules. Interpreting briefs to create high-quality coding that functions according to specifications. Identifying and resolving immediate and potential issues with applications. Your qualifications: At least 8 years’ experience in Java-based programming. Strong Experience on  Java Enterprise (JEE)  Programming and  RDBMS . In-depth knowledge of popular  Java frameworks,  SDKs, APIs, and libraries, including Swing. Experience with  Object-Oriented Design (OOD)  and developi

Deserialization error causing Kafka Streams to stop working even in presence of DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG property

If you are getting an exception during your kafka stream thread processing for which stack trace resembles what is below and you are wondering why your DeserializationExceptionHandler is not being invoked (which is written to ignore a deserialization error on a particular record), you are probably like me who have spent hours trying to figure out that. Ultimately I had to look closely on the stack trace and underlying Kafka streams library, I figured out this error is not occurring when a record is being processed from Kafka topic. Instead, it is being processed when a record from a State store is being retrieved (Notice the StateSerdes in the exception stack trace). Kafka doesn't use the handler in DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG when it reads the RocksDB files (see that the stacktrace mentions the class StateSerdes). That's why it works fine for records coming from the source topic, but fails when deserializing the data in the table. You would need to l