[GitHub] alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

[GitBox]

alexeyt820 commented on issue #6615: [FLINK-8354] [flink-connectors] Add 
ability to access and provider Kafka headers
URL: https://github.com/apache/flink/pull/6615#issuecomment-456910348
 
 
   Weird build is fine locally using 1.8.0_181-b13, but fails on Travis with 
1.8.0_151-b12:
   
   >17:38:32.202 [ERROR] 
/home/travis/build/apache/flink/flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/JSONKeyValueDeserializationSchemaTest.java:[105,71]
 cannot infer type arguments for 
org.apache.kafka.clients.consumer.ConsumerRecord<>
   
   for following lines:
   ```
                final ConsumerRecord<byte[], byte[]> consumerRecord = new 
ConsumerRecord<>(
                        "topic#1", 3, serializedKey, serializedValue, 4L);
   
   ```
   
   Any ideas?

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services