[GitHub] [camel-k] athira000babu commented on issue #4270: error while increasing the consumer count in kafka

["athira000babu (via GitHub)" <gi...@apache.org>]

athira000babu commented on issue #4270:
URL: https://github.com/apache/camel-k/issues/4270#issuecomment-1521615627

   2023-04-25 10:52:06,257 WARN  [org.apa.cam.com.kaf.KafkaConsumer] (Camel (camel-1) thread #2 - KafkaConsumer[books]) Error during processing. Exchange[35B1B9B2038C956-000000000000752D]. Caused by: [org.springframework.dao.DuplicateKeyException - PreparedStatementCallback; ERROR: duplicate key value violates unique constraint "books_pkey"
     Detail: Key (id)=(2_2500) already exists.; nested exception is org.postgresql.util.PSQLException: ERROR: duplicate key value violates unique constraint "books_pkey"
     Detail: Key (id)=(2_2500) already exists.]: org.springframework.dao.DuplicateKeyException: PreparedStatementCallback; ERROR: duplicate key value violates unique constraint "books_pkey"
     Detail: Key (id)=(2_2500) already exists.; nested exception is org.postgresql.util.PSQLException: ERROR: duplicate key value violates unique constraint "books_pkey"
     Detail: Key (id)=(2_2500) already exists.
   	at org.springframework.jdbc.support.SQLErrorCodeSQLExceptionTranslator.doTranslate(SQLErrorCodeSQLExceptionTranslator.java:247)
   	at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:70)
   	at org.springframework.jdbc.core.JdbcTemplate.translateException(JdbcTemplate.java:1541)
   	at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:667)
   	at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:685)
   	at org.apache.camel.component.sql.SqlProducer.processInternal(SqlProducer.java:145)
   	at org.apache.camel.component.sql.SqlProducer.process(SqlProducer.java:132)
   	at org.apache.camel.support.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:66)
   	at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:172)
   	at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:477)
   	at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:181)
   	at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:59)
   	at org.apache.camel.processor.Pipeline.process(Pipeline.java:175)
   	at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:392)
   	at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
   	at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
   	at org.apache.camel.component.kafka.consumer.support.KafkaRecordProcessor.processExchange(KafkaRecordProcessor.java:109)
   	at org.apache.camel.component.kafka.consumer.support.KafkaRecordProcessorFacade.processRecord(KafkaRecordProcessorFacade.java:124)
   	at org.apache.camel.component.kafka.consumer.support.KafkaRecordProcessorFacade.processPolledRecords(KafkaRecordProcessorFacade.java:77)
   	at org.apache.camel.component.kafka.KafkaFetchRecords.startPolling(KafkaFetchRecords.java:318)
   	at org.apache.camel.component.kafka.KafkaFetchRecords.run(KafkaFetchRecords.java:158)
   	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
   	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
   	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
   	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
   	at java.base/java.lang.Thread.run(Thread.java:829)
   Caused by: org.postgresql.util.PSQLException: ERROR: duplicate key value violates unique constraint "books_pkey"
     Detail: Key (id)=(2_2500) already exists.
   	at org.postgresql.core.v3.QueryExecutorImpl.receiveErrorResponse(QueryExecutorImpl.java:2676)
   	at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2366)
   	at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:356)
   	at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:496)
   	at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:413)
   	at org.postgresql.jdbc.PgPreparedStatement.executeWithFlags(PgPreparedStatement.java:190)
   	at org.postgresql.jdbc.PgPreparedStatement.execute(PgPreparedStatement.java:177)
   	at org.apache.commons.dbcp2.DelegatingPreparedStatement.execute(DelegatingPreparedStatement.java:94)
   	at org.apache.commons.dbcp2.DelegatingPreparedStatement.execute(DelegatingPreparedStatement.java:94)
   	at org.apache.camel.component.sql.SqlProducer$1.doInPreparedStatement(SqlProducer.java:161)
   	at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:651)
   
   
   


-- 
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-unsubscribe@camel.apache.org

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