Build #872

Build: #872 was successful

Job: Kafka was successful

Stages & jobs

  1. Default Stage

Job result summary

Completed
Duration
6 minutes
Agent
bamboo-18.af.pivotal.io
Revision
c5c5f444e03ff8f1c7c294a7d4b41627c136ca20 c5c5f444e03ff8f1c7c294a7d4b41627c136ca20
Total tests
164
First to pass since
#869 (Code changes detected – )

Tests

  • 164 tests in total
  • 1 test was fixed
  • 8 tests were quarantined / skipped
  • 5 minutes taken in total.
Fixed tests 1
Status Test Failing since Duration
Successful KafkaReceiverTest sendTransactionalReadCommitted History
Failing since build #870 (Code changes detected) < 1 sec

Error summary

The build generated some errors. See the full build log for more details.

  where K,V are type-variables:
    K extends Object declared in interface Consumer
    V extends Object declared in interface Consumer
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/src/test/java/reactor/kafka/receiver/internals/ChaosConsumerFactory.java:32: warning: [rawtypes] found raw type: Class
            new Class[]{org.apache.kafka.clients.consumer.Consumer.class},
                ^
  missing type arguments for generic class Class<T>
  where T is a type-variable:
    T extends Object declared in class Class
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/src/test/java/reactor/kafka/receiver/internals/ChaosConsumerFactory.java:42: warning: [unchecked] unchecked method invocation: constructor <init> in class HashMap is applied to given types
                                Map<TopicPartition, OffsetAndMetadata> offsets = new HashMap<>((Map) args[0]);
                                                                                 ^
  required: Map<? extends K,? extends V>
  found: Map
  where K,V are type-variables:
    K extends Object declared in class HashMap
    V extends Object declared in class HashMap
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/src/test/java/reactor/kafka/receiver/internals/ChaosConsumerFactory.java:42: warning: [unchecked] unchecked conversion
                                Map<TopicPartition, OffsetAndMetadata> offsets = new HashMap<>((Map) args[0]);
                                                                                               ^
  required: Map<? extends K,? extends V>
  found:    Map
  where K,V are type-variables:
    K extends Object declared in class HashMap
    V extends Object declared in class HashMap
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/src/test/java/reactor/kafka/receiver/internals/ChaosConsumerFactory.java:42: warning: [unchecked] unchecked conversion
                                Map<TopicPartition, OffsetAndMetadata> offsets = new HashMap<>((Map) args[0]);
                                                                                 ^
  required: Map<TopicPartition,OffsetAndMetadata>
  found:    HashMap
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/src/test/java/reactor/kafka/receiver/internals/ChaosConsumerFactory.java:30: warning: [unchecked] unchecked cast
        return (org.apache.kafka.clients.consumer.Consumer<K, V>) Proxy.newProxyInstance(
                                                                                        ^
  required: Consumer<K,V>
  found:    Object
  where K,V are type-variables:
    K extends Object declared in method <K,V>createConsumer(ReceiverOptions<K,V>)
    V extends Object declared in method <K,V>createConsumer(ReceiverOptions<K,V>)
16 warnings
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/ConsumerPerformance.java:263: warning: [deprecation] poll(long) in KafkaConsumer has been deprecated
                consumer.poll(100);
                        ^
  where K,V are type-variables:
    K extends Object declared in class KafkaConsumer
    V extends Object declared in class KafkaConsumer
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/ConsumerPerformance.java:273: warning: [deprecation] poll(long) in KafkaConsumer has been deprecated
                ConsumerRecords<byte[], byte[]> records = consumer.poll(100);
                                                                  ^
  where K,V are type-variables:
    K extends Object declared in class KafkaConsumer
    V extends Object declared in class KafkaConsumer
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/EndToEndLatency.java:308: warning: [deprecation] poll(long) in KafkaConsumer has been deprecated
                consumer.poll(100);
                        ^
  where K,V are type-variables:
    K extends Object declared in class KafkaConsumer
    V extends Object declared in class KafkaConsumer
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/EndToEndLatency.java:312: warning: [deprecation] poll(long) in KafkaConsumer has been deprecated
            consumer.poll(0);
                    ^
  where K,V are type-variables:
    K extends Object declared in class KafkaConsumer
    V extends Object declared in class KafkaConsumer
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/reactor-kafka-tools/src/main/java/reactor/kafka/tools/perf/EndToEndLatency.java:316: warning: [deprecation] poll(long) in KafkaConsumer has been deprecated
            Iterator<ConsumerRecord<byte[], byte[]>> recordIter = consumer.poll(timeout).iterator();
                                                                          ^
  where K,V are type-variables:
    K extends Object declared in class KafkaConsumer
    V extends Object declared in class KafkaConsumer
5 warnings
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/src/main/java/reactor/kafka/sender/KafkaSender.java:27: error: package reactor.kafka.sender.internals does not exist
import reactor.kafka.sender.internals.DefaultKafkaSender;
                                     ^
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/src/main/java/reactor/kafka/sender/KafkaSender.java:28: error: package reactor.kafka.sender.internals does not exist
import reactor.kafka.sender.internals.ProducerFactory;
                                     ^
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/src/main/java/reactor/kafka/sender/KafkaSender.java:59: error: cannot find symbol
    static <K, V> KafkaSender<K, V> create(ProducerFactory factory, SenderOptions<K, V> options) {
                                           ^
  symbol:   class ProducerFactory
  location: interface KafkaSender<K,V>
  where K,V are type-variables:
    K extends Object declared in interface KafkaSender
    V extends Object declared in interface KafkaSender
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/src/main/java/reactor/kafka/receiver/KafkaReceiver.java:26: error: package reactor.kafka.receiver.internals does not exist
import reactor.kafka.receiver.internals.ConsumerFactory;
                                       ^
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/src/main/java/reactor/kafka/receiver/KafkaReceiver.java:27: error: package reactor.kafka.receiver.internals does not exist
import reactor.kafka.receiver.internals.DefaultKafkaReceiver;
                                       ^
/opt/bamboo-home/xml-data/build-dir/REACTOR-RKAFKA-AERON/src/main/java/reactor/kafka/receiver/KafkaReceiver.java:63: error: cannot find symbol
    static <K, V> KafkaReceiver<K, V> create(ConsumerFactory factory, ReceiverOptions<K, V> options) {
                                             ^
  symbol:   class ConsumerFactory
  location: interface KafkaReceiver<K,V>
  where K,V are type-variables:
    K extends Object declared in interface KafkaReceiver
    V extends Object declared in interface KafkaReceiver
warning: unknown enum constant When.MAYBE
  reason: class file for javax.annotation.meta.When not found