SHARE
TWEET

Untitled

a guest Jun 16th, 2019 78 Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. This should not happen as headers() should only be called while a record is processed
  2. java.lang.IllegalStateException: This should not happen as headers() should only be called while a record is processed
  3.         at org.apache.kafka.streams.processor.internals.AbstractProcessorContext.headers(AbstractProcessorContext.java:149)
  4.         at org.apache.kafka.streams.state.internals.CachingKeyValueStore.putInternal(CachingKeyValueStore.java:235)
  5.         at org.apache.kafka.streams.state.internals.CachingKeyValueStore.put(CachingKeyValueStore.java:222)
  6.         at org.apache.kafka.streams.state.internals.CachingKeyValueStore.put(CachingKeyValueStore.java:37)
  7.         at org.apache.kafka.streams.state.internals.MeteredKeyValueStore.put(MeteredKeyValueStore.java:153)
  8.         at org.apache.kafka.streams.processor.internals.ProcessorContextImpl$KeyValueStoreReadWriteDecorator.put(ProcessorContextImpl.java:446)
  9.         at fr.mediametrie.GeoIPEnrichmentProcessor.transform(GeoIPEnrichmentProcessor.java:97)
  10.         at fr.mediametrie.GeoIPEnrichmentProcessor.transform(GeoIPEnrichmentProcessor.java:1)
  11.         at org.apache.kafka.streams.kstream.internals.TransformerSupplierAdapter$1.transform(TransformerSupplierAdapter.java:47)
  12.         at org.apache.kafka.streams.kstream.internals.TransformerSupplierAdapter$1.transform(TransformerSupplierAdapter.java:36)
  13.         at org.apache.kafka.streams.kstream.internals.KStreamFlatTransform$KStreamFlatTransformProcessor.process(KStreamFlatTransform.java:56)
  14.         at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:117)
  15.         at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:183)
  16.         at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:162)
  17.         at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:122)
  18.         at org.apache.kafka.streams.processor.internals.SourceNode.process(SourceNode.java:87)
  19.         at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:364)
  20.         at org.apache.kafka.streams.processor.internals.AssignedStreamsTasks.process(AssignedStreamsTasks.java:199)
  21.         at org.apache.kafka.streams.processor.internals.TaskManager.process(TaskManager.java:420)
  22.         at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:890)
  23.         at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:805)
  24.         at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:774)
RAW Paste Data
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy. OK, I Understand
 
Top