Re: Kafka - Failed to stream a record with null key

[austin solomon]

Hi Roman, 

I am trying to assign timestamp value to record.key() in IgniteSinkTask.java
file but i am getting an 

Error :  the left-hand side of an assignment must be a variable java, on 
record.key() = new Timestamp(date.getTime());

My code is like this : 

try {
            for (SinkRecord record : records) {
                if (record.key() == null) {
                        java.util.Date date= new java.util.Date();
                        record.key() = new Timestamp(date.getTime());
                        StreamerContext.getStreamer().addData(record.key(),
record.value());
                }
}

Can you please help me on this?

Thanks,
Austin





--
View this message in context: 
http://apache-ignite-users.70518.x6.nabble.com/Kafka-Failed-to-stream-a-record-with-null-key-tp8731p8815.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.