ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From austin solomon <austin.solomon...@gmail.com>
Subject Kafka - Failed to stream a record with null key
Date Mon, 07 Nov 2016 13:25:41 GMT

I am using Kafka Streamer module to pump the data from Kafka to Ignite
cache, by following the documentation given in the below link


I could able to sink the data in ignite's cache. However when i tried to
achieve the same Confluent I got the following error

ERROR Failed to stream a record with null key!

    @Override public void put(Collection<SinkRecord> records) {
        try {
            for (SinkRecord record : records) {
                if (record.key() != null) {
                    // Data is flushed asynchronously when
                else {
                    log.error("Failed to stream a record with null key!");

        catch (ConnectException e) {
            log.error("Failed adding record", e);

            throw new ConnectException(e);

After some analysis I found that this problem might be occurred since I have
not provided  the properties like 
--property parse.key=true --property key.separator=,

My question here is, Is it possible to pass this properties in kafka's
worker configuration file like connect.standalone ?

Thanks in advance !!


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

View raw message