S } ::: true 19:23:37.915 [Camel (promoIntegrationContext) thread #59 - KafkaConsumer[mytopic]] WARN o.a.c.component.kafka.KafkaConsumer - Error consuming mytopic-Thread 5 from kafka topic. Caused by: [java.lang.IllegalArgumentException - Unknown compression type id: 4] java.lang.IllegalArgumentException: Unknown compression type id: 4 at org.apache.kafka.common.record.CompressionType.forId(CompressionType.java:46) at org.apache.kafka.common.record.Record.compressionType(Record.java:260) at org.apache.kafka.common.record.LogEntry.isCompressed(LogEntry.java:89) at org.apache.kafka.common.record.RecordsIterator.makeNext(RecordsIterator.java:70) at org.apache.kafka.common.record.RecordsIterator.makeNext(RecordsIterator.java:34) at org.apache.kafka.common.utils.AbstractIterator.maybeComputeNext(AbstractIterator.java:79) at org.apache.kafka.common.utils.AbstractIterator.hasNext(AbstractIterator.java:45) at org.apache.kafka.clients.consumer.internals.Fetcher.parseCompletedFetch(Fetcher.java:785) at org.apache.kafka.clients.consumer.internals.Fetcher.fetchedRecords(Fetcher.java:480) at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1037) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:995) at org.apache.camel.component.kafka.KafkaConsumer$KafkaFetchRecords.run(KafkaConsumer.java:130) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) 19:23:37.916 [Camel (promoIntegrationContext) thread #58 - KafkaConsumer[mytopic]] INFO ------------------------------------------- 19:23:43.400 [Camel (promoIntegrationContext) thread #56 - KafkaConsumer[mytopic]] WARN o.a.c.component.kafka.KafkaConsumer - Error consuming mytopic-Thread 2 from kafka topic. Caused by: [java.lang.IllegalArgumentException - Unknown compression type id: 5] java.lang.IllegalArgumentException: Unknown compression type id: 5 at org.apache.kafka.common.record.CompressionType.forId(CompressionType.java:46) at org.apache.kafka.common.record.Record.compressionType(Record.java:260) at org.apache.kafka.common.record.LogEntry.isCompressed(LogEntry.java:89) at org.apache.kafka.common.record.RecordsIterator.makeNext(RecordsIterator.java:70) at org.apache.kafka.common.record.RecordsIterator.makeNext(RecordsIterator.java:34) at org.apache.kafka.common.utils.AbstractIterator.maybeComputeNext(AbstractIterator.java:79) at org.apache.kafka.common.utils.AbstractIterator.hasNext(AbstractIterator.java:45) at org.apache.kafka.clients.consumer.internals.Fetcher.parseCompletedFetch(Fetcher.java:785) at org.apache.kafka.clients.consumer.internals.Fetcher.fetchedRecords(Fetcher.java:480) at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1037) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:995) at org.apache.camel.component.kafka.KafkaConsumer$KafkaFetchRecords.run(KafkaConsumer.java:130) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) 19:23:43.400 [Camel (promoIntegrationContext) thread #54 - KafkaConsumer[mytopic]] INFO ------------------------------------------- 17:59:06.104 [Camel (promoIntegrationContext) thread #54 - KafkaConsumer[mytopic]] WARN o.a.c.component.kafka.KafkaConsumer - Error consuming mytopic-Thread 0 from kafka topic. Caused by: [java.lang.IllegalArgumentException - Unknown compression type id: 6] java.lang.IllegalArgumentException: Unknown compression type id: 6 at org.apache.kafka.common.record.CompressionType.forId(CompressionType.java:46) at org.apache.kafka.common.record.Record.compressionType(Record.java:260) at org.apache.kafka.common.record.LogEntry.isCompressed(LogEntry.java:89) at org.apache.kafka.common.record.RecordsIterator.makeNext(RecordsIterator.java:70) at org.apache.kafka.common.record.RecordsIterator.makeNext(RecordsIterator.java:34) at org.apache.kafka.common.utils.AbstractIterator.maybeComputeNext(AbstractIterator.java:79) at org.apache.kafka.common.utils.AbstractIterator.hasNext(AbstractIterator.java:45) at org.apache.kafka.clients.consumer.internals.Fetcher.parseCompletedFetch(Fetcher.java:785) at org.apache.kafka.clients.consumer.internals.Fetcher.fetchedRecords(Fetcher.java:480) at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1037) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:995) at org.apache.camel.component.kafka.KafkaConsumer$KafkaFetchRecords.run(KafkaConsumer.java:130) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) 17:59:06.101 [Camel (camel) thread #41 - KafkaConsumer[delta]] INFO ------------------------------------------- 17:59:01.278 [Camel (camel) thread #13 - KafkaConsumer[mytopic]] WARN o.a.c.component.kafka.KafkaConsumer - Error consuming mytopic-Thread 1 from kafka topic. Caused by: [java.lang.IllegalArgumentException - Unknown compression type id: 7] java.lang.IllegalArgumentException: Unknown compression type id: 7 at org.apache.kafka.common.record.CompressionType.forId(CompressionType.java:46) at org.apache.kafka.common.record.Record.compressionType(Record.java:260) at org.apache.kafka.common.record.LogEntry.isCompressed(LogEntry.java:89) at org.apache.kafka.common.record.RecordsIterator.makeNext(RecordsIterator.java:70) at org.apache.kafka.common.record.RecordsIterator.makeNext(RecordsIterator.java:34) at org.apache.kafka.common.utils.AbstractIterator.maybeComputeNext(AbstractIterator.java:79) at org.apache.kafka.common.utils.AbstractIterator.hasNext(AbstractIterator.java:45) at org.apache.kafka.clients.consumer.internals.Fetcher.parseCompletedFetch(Fetcher.java:785) at org.apache.kafka.clients.consumer.internals.Fetcher.fetchedRecords(Fetcher.java:480) at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1037) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:995) at org.apache.camel.component.kafka.KafkaConsumer$KafkaFetchRecords.run(KafkaConsumer.java:130) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) 17:59:01.278 [Camel (camel) thread #36 - KafkaConsumer[delta]] INFO ------------------------------------------- 19:19:29.095 [Camel (camel) thread #14 - KafkaConsumer[mytopic]] WARN o.a.c.component.kafka.KafkaConsumer - Error consuming mytopic-Thread 2 from kafka topic. Caused by: [java.lang.IndexOutOfBoundsException - null] java.lang.IndexOutOfBoundsException: null at java.nio.Buffer.checkIndex(Buffer.java:546) at java.nio.HeapByteBuffer.getInt(HeapByteBuffer.java:365) at org.apache.kafka.common.utils.Utils.sizeDelimited(Utils.java:784) at org.apache.kafka.common.record.Record.value(Record.java:268) at org.apache.kafka.common.record.RecordsIterator$DeepRecordsIterator.(RecordsIterator.java:149) at org.apache.kafka.common.record.RecordsIterator.makeNext(RecordsIterator.java:79) at org.apache.kafka.common.record.RecordsIterator.makeNext(RecordsIterator.java:34) at org.apache.kafka.common.utils.AbstractIterator.maybeComputeNext(AbstractIterator.java:79) at org.apache.kafka.common.utils.AbstractIterator.hasNext(AbstractIterator.java:45) at org.apache.kafka.clients.consumer.internals.Fetcher.parseCompletedFetch(Fetcher.java:785) at org.apache.kafka.clients.consumer.internals.Fetcher.fetchedRecords(Fetcher.java:480) at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1037) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:995) at org.apache.camel.component.kafka.KafkaConsumer$KafkaFetchRecords.run(KafkaConsumer.java:130) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) 19:19:29.096 [Camel (camel) thread #16 - KafkaConsumer[mytopic]] INFO -------------------------------------------