MINOR Fix AsyncProducerTest bug that hits when logging is turned up

[cmccabe]

AsyncProducerTest gets an error about an incorrect mock when the logging
level is turned up. Instead of using a mock, just create a real
SyncProducerConfig object, since the object is simple to create.

[cmccabe]

The error message when logging is set to TRACE looks like this:

    [2018-01-19 11:42:37,266] WARN Failed to send producer request with correlation id 11 to broker 0 with data for partitions topic1-1,topic1-0 (kafka.producer.async.DefaultEventHandler:69)
    java.lang.IllegalStateException: missing behavior definition for the preceding method call:
    SyncProducerConfig.host()
    Usage is: expect(a.foo()).andXXX()
        at org.easymock.internal.MockInvocationHandler.invoke(MockInvocationHandler.java:42)
        at org.easymock.internal.ObjectMethodsFilter.invoke(ObjectMethodsFilter.java:94)
        at org.easymock.internal.ClassProxyFactory$MockMethodInterceptor.intercept(ClassProxyFactory.java:95)
        at kafka.producer.SyncProducerConfig$$EnhancerByCGLIB$$69b88809.host(<generated>)
        at kafka.producer.async.DefaultEventHandler$$anonfun$kafka$producer$async$DefaultEventHandler$$send$2.apply(DefaultEventHandler.scala:274)
        at kafka.producer.async.DefaultEventHandler$$anonfun$kafka$producer$async$DefaultEventHandler$$send$2.apply(DefaultEventHandler.scala:274)
        at kafka.utils.Logging$class.debug(Logging.scala:59)
        at kafka.producer.async.DefaultEventHandler.debug(DefaultEventHandler.scala:38)
        at kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$send(DefaultEventHandler.scala:273)
        at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:116)
        at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:108)
        at scala.collection.TraversableLike$WithFilter$$anonfun$foreach$1.apply(TraversableLike.scala:733)
        at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:130)
        at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:130)
        at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:236)
        at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:40)
        at scala.collection.mutable.HashMap.foreach(HashMap.scala:130)
        at scala.collection.TraversableLike$WithFilter.foreach(TraversableLike.scala:732)
        at kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:108)
        at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:81)
        at kafka.producer.AsyncProducerTest.testFailedSendRetryLogic(AsyncProducerTest.scala:432)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)

[ijuma]

Thanks for the PR, LGTM.

[ijuma]

retest this please

[cmccabe]

retest this please

[cmccabe]

Another Jenkins infrastructure failure (no build or testing was done):

18:58:01 ERROR: No tool found matching GRADLE_3_4_RC_2_HOME
18:58:01 Setting GRADLE_3_5_HOME=/home/jenkins/tools/gradle/3.5
18:58:01 [kafka-pr-jdk8-scala2.12] $ /bin/bash -xe /tmp/jenkins7846209012933300131.sh
18:58:01 + rm -rf /home/jenkins/jenkins-slave/workspace/kafka-pr-jdk8-scala2.12/.gradle
18:58:01 + /home/jenkins/tools/gradle/3.5/bin/gradle
18:58:01 /tmp/jenkins7846209012933300131.sh: line 4: /home/jenkins/tools/gradle/3.5/bin/gradle: No such file or directory
18:58:01 Build step 'Execute shell' marked build as failure

[cmccabe]

retest this please

[cmccabe]

I filed https://issues.apache.org/jira/browse/INFRA-15903 for the Jenkins issue. We have seen it before.

[cmccabe]

Another unrelated failure in org.apache.kafka.streams.integration.ResetIntegrationTest

[cmccabe]

JDK7 failure was streams test timeout. Will retry.

00:23:45 Build timed out (after 180 minutes). Marking the build as aborted.
00:24:38 Build was aborted
00:24:38 :streams:integrationTest FAILED
00:24:38 
00:24:38 FAILURE: Build failed with an exception.
00:24:38 
00:24:38 * What went wrong:
00:24:38 Execution failed for task ':streams:integrationTest'.

[cmccabe]

Retest this please

[cmccabe]

retest this please

[cmccabe]

retest this please

[asfgit]

Refer to this link for build results (access rights to CI server needed):
https://builds.apache.org/job/kafka-pr-test-coverage/198/

[cmccabe]

retest this please

[cmccabe]

The test run succeeded, but then jenkins got this:

19:25:47 ERROR: Step ?Publish coverage to GitHub? aborted due to exception: 
19:25:47 java.io.IOException: Exceeded rate limit for repository
19:25:47 	at com.github.terma.jenkins.githubprcoveragestatus.GitHubPullRequestRepository.getGitHubRepository(GitHubPullRequestRepository.java:46)
19:25:47 Caused: java.io.IOException: Error while accessing rate limit API
19:25:47 	at com.github.terma.jenkins.githubprcoveragestatus.GitHubPullRequestRepository.getGitHubRepository(GitHubPullRequestRepository.java:51)