kranthi chamarthi

Ranch Hand
+ Follow
since May 08, 2007
Merit badge: grant badges
For More
Cows and Likes
Cows
Total received
0
In last 30 days
0
Total given
0
Likes
Total received
0
Received in last 30 days
0
Total given
0
Given in last 30 days
0
Forums and Threads
Scavenger Hunt
expand Ranch Hand Scavenger Hunt
expand Greenhorn Scavenger Hunt

Recent posts by kranthi chamarthi

Hi,

I am working on coming up with a kafka consumer based on springboot. There is requirement to commit offset within consumer program instead of relying upon auto commit provided by kafka. So when explored on options to do this I found two ways
1. To create ConcurrentMessageListenerContainer within kafka configuration bean by passing acknowledgement mode as AckMode.MANUAL_IMMEDIATE. Pass the reference of class that implements AcknowledgingMessageListener. This will give handle to Acknowledgement object in onMessage method. In onMessage we can consume message then if no exceptions are there we can invoke acknowledge() on Acknowledgement object.
2. To create ConcurrentKafkaListenerContainerFactory within kafka configuration bean by passing acknowledgement mode as AckMode.MANUAL_IMMEDIATE. Then have @KafkaListener annotation with topics and groupid defined. listen method contains handle to Acknowledgement object and once processing of message is completed we can invoke acknowledge() on Acknowledgement object.

Want to understand the pros and cons of above two approaches. To me right now both approaches seems to be achieving same functionality, so if I am implementing kafka consumer, which approach is better to adopt.

Thanks
Kranthi
3 years ago
Hi

I am having requirement to read data(some of the tables containing millions of records) from multiple tables(around 10 tables) in oracle then do some transformation and load this data onto cassandra. What would be the best way to do this.
Following is the approach that i can think of
1 Use apache camel for connecting to oracle, have separate camel routes to read data from each of the tables(if 10 tables then 10 routes will be defined). then drop these messages into kafka topics(data from each route will be dropped into separate kafka topic). Now there will be routes defined to read data from each of these kafka topics(10 consumers to consume from 10 kafka topics), do necessary transformation in batches using logic in processor(if required will execute processor in multi threaded mode) then connect to cassandra's keyspace and insert the data read.

Can you suggest me if this approach is a good way to perform data migration task between two databases when you have huge data. Will above approach have any scalability issues.
If there are any tweaks to be made to above approach or alternative frameworks best suited for this requirement please suggest.
Note: Source database can vary. In some cases it can be DB2
Hi...I have this requirement to modify the body(body contains an xml) coming within HttpServletRequest based on value of a header..Like if Header1 comes with vaue of Value1 within header then set a new attribute within xml coming in body and pass it along to servlet down the line. Is this doable if so can i do this within servlet filter? Or this manipulation of request within filters is not allowed?

Thanks
Kranthi
4 years ago
Forget to mention one point..In both Postman as well as standalone program i am not using any username and password as well as not defining any Authentication Type.
6 years ago
Hi..I have a web application containing a servlet and some buisiness logic code. It can be accessed via https url(from a particular port). When i try to invoke the https url from Postman it is able to access the webapplication and give response. But when i try to invoke this https url via a stand alone program using java.net.HttpURLConnection i am getting below exception! As per my understanding behavior should be same like either https url can be accessible by both Postman and standalone program or both should be throwing SSLHandshakeException. Can anyone guide me why this might be happening. Do i need to change something in my program.

javax.net.ssl.SSLHandshakeException: sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target
at sun.security.ssl.Alerts.getSSLException(Unknown Source)
at sun.security.ssl.SSLSocketImpl.fatal(Unknown Source)
at sun.security.ssl.Handshaker.fatalSE(Unknown Source)
6 years ago
Hi Everyone..I have cleared SCJP 5 certification sometime in 2010 and now with all the latest features of jdk 8..planning to prepare and take OCJP8. Now my question is..can i take OCJP8 directly or do i need to clear OCJA8 for eligibility to OCJP8..Also i have seen in oracle website that the fee for OCJP8 is $245. Is there any chance that we can get discount on voucher. Thanks in advance.
Hi,

Only one of the two attributes which is having value should be declared on element. Suppose ApiName attribute is having value then Api tag will be as below

If FlowName is having value then

Blank value should not be considered as value. If none of ApiName or FlowName are specified with value then an error should be shown. Please advise.

Thanks
Kranthi

Please let me know if there ia any way of accomplishing this in xsd...
Hi,

Can is use xs:choice in case of attributes to achieve above functionality or its only in case of element that we can use choice indicator. Please advise...
Thanks g tsuji . I overlooked the point that i should specify processContent as skip for Template as well.... Its working now.
Sorry for late reply... But my requirement is to find out all attributes in input xml which has attribute value in a pattern like ${VariableName}. Then i will get the corresponding value for this VariableName from a collection and substitute this as the value for the attribute. Its like i make an api call, get output, i have to use some values in this output and prepare the input dynalically to the next api call. I thought rather than using DOM to traverse through xml and check for each attribute in each element for value in format ${VariableName}, it will be better performance wise to use Pattern matching, to get the attributes for which values needs to be populated dynamically.

I agree that writing correct regex pattern for this task is a bit error prone.
10 years ago
Hi,

The xml that i am trying to validate is something like below


and the xsd i am using is like below


I dont want the Order xml present under Input element to be validated against xsd. Please suggest.

Regards,
Kranthi
Hi,

I am preparing an xsd to validate input xml to a tool. Now I need only some of the elements to be validated against xsd and some to be skipped. For example i have below xml to be validated

Now i want my xsd to validate until Input element and to skip Order and its children(in bold above).
I tried googling and found something called xs:any element which can be used with processContents="skip"
I tried using it in below way in my xsd

But when i run my java class that validates above xml with my xsd, it shows

Any suggestions on this will be helpful.

Regards
Kranthi
I am trying to code an xsd to validate input xml to a tool. There is a requirement where an element is having two attributes and one of the attributes must definetely have a value

In above either ApiName or FlowName must have a value. How to specify this in xsd. Please advise.

Thanks,
Kranthi
Hi,

I am reading an xml then converting it into a String. Now I have an Element in this xml which is converted into String, shown as below

I am trying to use pattern matching to get all the attributes and their corresponding values in this Element which are having $
I am trying to use the pattern

But when i use matcher.group() method it gives output as

where as the expected output is

I tried to add some Reluctant quantifiers but, was not able to resolve this. Any inputs will be helpful.

Thanks
Kranthi
10 years ago