Re: Why do I get an IllegalStateException when accessing record metadata?

2019-01-06 Thread Peter Levart
the following way (highlighted text is my addition):    Why do I get an IllegalStateException when accessing record metadata?    If you attach a new |Processor/Transformer/ValueTransformer| to your    topology using a corresponding supplier, you need to make sure that    the supplier retur

Re: Why do I get an IllegalStateException when accessing record metadata?

2019-01-03 Thread Matthias J. Sax
ntered IllegalStateExceptions in my KafkaTransformer. My >>> application was exhibiting all of the behavior as discussed in the FAQ >>> (https://cwiki.apache.org/confluence/display/KAFKA/FAQ), under the >>> section: >>> >>> Why do I get an IllegalStateEx

Re: Why do I get an IllegalStateException when accessing record metadata?

2019-01-03 Thread Eric Lalonde
t;> Recently I encountered IllegalStateExceptions in my KafkaTransformer. My >> application was exhibiting all of the behavior as discussed in the FAQ >> (https://cwiki.apache.org/confluence/display/KAFKA/FAQ), under the section: >> >> Why do I get an IllegalStateExceptio

Re: Why do I get an IllegalStateException when accessing record metadata?

2019-01-02 Thread Matthias J. Sax
n the following way (highlighted text is my addition): > > > Why do I get an IllegalStateException when accessing record metadata?  > > If you attach a new |Processor/Transformer/ValueTransformer| to your > topology using a corresponding supplier, you need to make sure

Re: Why do I get an IllegalStateException when accessing record metadata?

2018-12-30 Thread Eric Lalonde
ighted text is my addition): Why do I get an IllegalStateException when accessing record metadata? If you attach a new Processor/Transformer/ValueTransformer to your topology using a corresponding supplier, you need to make sure that the supplier returns a new instance each time get() is called.