Skip to content

AK to CCS merge for 03 june 2019#8791

Closed
agg111 wants to merge 272 commits intoapache:trunkfrom
confluentinc:sync-upstream-03-june-2019
Closed

AK to CCS merge for 03 june 2019#8791
agg111 wants to merge 272 commits intoapache:trunkfrom
confluentinc:sync-upstream-03-june-2019

Conversation

@agg111
Copy link
Copy Markdown
Contributor

@agg111 agg111 commented Jun 3, 2020

There was a version bump in AK to 2.7.0-SNAPSHOT. The merge needed to be applied manually.

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

dhruvilshah3 and others added 30 commits December 6, 2018 19:14
* ak/trunk:
  KAFKA-7709: Fix ConcurrentModificationException when retrieving expired inflight batches on multiple partitions. (apache#6005)
* apache-github/trunk:
  MINOR: improve Streams checkstyle and code cleanup (apache#5954)
  KAFKA-6970: All standard state stores guarded with read only wrapper (apache#6016)
  KAFKA-7443: OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic (apache#5946)
  KAFKA-7610; Proactively timeout new group members if rebalance is delayed (apache#5962)
  KAFKA-7549; Old ProduceRequest with zstd compression does not return error to client (apache#5925)
  KAFKA-6036: Follow-up; cleanup sendOldValues logic ForwardingCacheFlushListener  (apache#6017)
  KAFKA-6036: Local Materialization for Source KTable (apache#5779)
  MINOR: fix checkpoint write failure warning log (apache#6008)
  MINOR: Catch NoRecordsException in testCommaSeparatedRegex() test (apache#5944)
  MINOR: Specify character encoding in NetworkTestUtils (apache#5965)
  MINOR: Fix failing ConsumeBenchTest:test_multiple_consumers_specified_group_partitions_should_raise (apache#6015)
…sh suffix (#80)

Since we want to retain the same base name for scripts as AK, it is less error-prone to just append `.sh` to the script name rather than get the directory and then add the script name. Also fixes issue with directories containing space.

Reviewers: Ismael Juma <ismael@juma.me.uk>
* apache-upstream/trunk:
  MINOR: Update README.md with Gradle 5+ requirement (apache#6039)
  MINOR: Include additional detail in fetch error message (apache#6036)
  MINOR: improve Streams error message (apache#5975)
  KAFKA-2334; Guard against non-monotonic offsets in the client (apache#5991)
  MINOR: Replace tbd with the actual link for out-of-ordering data (apache#6035)
  MINOR: Update documentation for internal changelog when using table(). (apache#6021)
  MINOR:Start processor inside verify message (apache#6029)
  Fix the missing ApiUtils tests in streams module. (apache#6003)
  KAFKA-7655 Metadata spamming requests from Kafka Streams under some circumstances, potential DOS (apache#5929)
  KAFKA-7223: document suppression buffer metrics (apache#6024)
  KAFKA-7712; Remove channel from Selector before propagating exception (apache#6023)
  KAFKA-7705; Fix and simplify producer config in javadoc example (apache#6000)
  MINOR: Add unit for max latency in ProducerPerformance output (apache#6014)
* apache/trunk:
  MINOR: Add test demonstrating re-use of KGroupedStream with Optimizations enabled (apache#6050)
  MINOR: Bump admin client retries for creating repartition topics (apache#6063)
  MINOR: Increase throughput for VerifiableProducer in test (apache#6060)
  KAFKA-7054; Kafka describe command should throw topic doesn't exist exception
  MINOR: Hygiene fixes in KafkaFutureImpl (apache#5098)
  MINOR: Switch anonymous classes to lambda expressions in tools module
  KAFKA-7759; Disable WADL output in the Connect REST API (apache#6051)
  KAFKA-7762; Update KafkaConsumer Javadoc examples to use poll(Duration timeout) API
  KAFKA-7742; Fixed removing hmac entry for a token being removed from DelegationTokenCache
  MINOR: Stabilization fixes broker down test trunk (apache#6043)
* apache-kafka/trunk:
  MINOR: Fix doc format in upgrade notes
  MINOR: Improve exception messages in FileChannelRecordBatch (apache#6068)
  KAFKA-3832; Kafka Connect's JSON Converter never outputs a null value (apache#6027)
* ak/trunk: (41 commits)
  KAFKA-7808: AdminClient#describeTopics should not throw InvalidTopic if topic name is not found (apache#6124)
  HOTFIX: Compilation error in CommandLineUtils (apache#6131)
  KAFKA-7790: Fix Bugs in Trogdor Task Expiration (apache#6103)
  MINOR: Need to have same wait as verify timeout broker upgrade downgrade (apache#6127)
  KAFKA-6627: Prevent config default values overriding ones specified through --producer-property on command line. (apache#6084)
  KAFKA-7741: Streams exclude javax dependency (apache#6121)
  MINOR: Remove throwing exception if not found from describe topics (apache#6112)
  KAFKA-5994; Log ClusterAuthorizationException for all ClusterAction requests
  MINOR: Update dependencies for Kafka 2.2 (apache#6116)
  MINOR: Add 2.1 version metadata upgrade (apache#6111)
  KAFKA-7786; Ignore OffsetsForLeaderEpoch response if epoch changed while request in flight (apache#6101)
  MINOR: Log successful/failed authentications with socket information (apache#5856)
  MINOR: code cleanup (apache#6053)
  MINOR: code cleanup (apache#6057)
  MINOR: code cleanup (apache#6055)
  KAFKA-7799; Fix flaky test RestServerTest.testCORSEnabled (apache#6106)
  KAFKA-6833; Producer should await metadata for unknown partitions (apache#6073)
  MINOR: Put states in proper order, increase timeout for starting (apache#6105)
  MINOR: code cleanup (apache#6056)
  KAFKA-7253; The returned connector type is always null when creating connector (apache#5470)
  ...
* AK/trunk:
  MINOR: log when controller begins processing logdir failure event (apache#6153)
  KAFKA-7829; Javadoc should show that AdminClient.alterReplicaLogDirs() is supported in Kafka 1.1.0 or later (apache#6157)
  KAFKA-7738; Track leader epochs in client Metadata (apache#6045)
  MINOR: Start Connect REST server in standalone mode to match distributed mode (KAFKA-7503 follow-up)
  KAFKA-7824; Require member.id for initial join group request [KIP-394] (apache#6058)
  KAFKA-7792: Add simple /agent/uptime and /coordinator/uptime health check endpoints (apache#6130)
  MINOR: Streams upgrade guide section for newly merged KIPs (apache#6108)
  MINOR: Add log entry for KafkaException in StreamThread#runLoop (apache#6144)
  KAFKA-7391; Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit) (apache#5667)
  MINOR: Update Trogdor StringExpander regex to handle an epilogue (apache#6123)
  KAFKA-7461: Add tests for logical types
  Fix KAFKA-7789 by increasing the key size for the RSA keys generated for (apache#6096)
  KAFKA-7503: Connect integration test harness
  MINOR: code cleanup (apache#6054)
  MINOR: Fix typo in security.html (apache#6141)
  HOTFIX: Fix Properties.putAll compiler error when compiling with Java 11 (apache#6140)
  MINOR: Put state args in correct order named repartition test (apache#6114)
  MINOR: clarify the record selection algorithm and stream-time definition (apache#6128)
  KAFKA-4453 : Added code to separate controller connections and requests from the data plane (apache#5921)
  KAFKA-7781; Add validation check for retention.ms topic property.
* ak/trunk:
  MINOR: fix race condition in KafkaStreamsTest (apache#6185)
  KAFKA-4850: Enable bloomfilters (apache#6012)
  MINOR: ducker-ak: add down -f, avoid using a terminal in ducker test
  KAFKA-5117: Stop resolving externalized configs in Connect REST API
  MINOR: Cleanup handling of mixed transactional/idempotent records (apache#6172)
  KAFKA-7844: Use regular subproject for generator to fix *All targets (apache#6182)
  Fix Documentation for cleanup.policy is out of date (apache#6181)
  MINOR: increase timeouts for KafkaStreamsTest (apache#6178)
  MINOR: Rejoin split ssl principal mapping rules (apache#6099)
  MINOR: Handle case where connector status endpoints returns 404 (apache#6176)
  MINOR: Remove unused imports, exceptions, and values (apache#6117)
  KAFKA-3522: Add internal RecordConverter interface (apache#6150)
  Fix Javadoc of KafkaConsumer (apache#6155)
  KAFKA-6455: Extend CacheFlushListener to forward timestamp (apache#6147)
  MINOR: Log partition info when creating new request batch in controller (apache#6145)
  KAFKA-7652: Part I; Fix SessionStore's findSession(single-key) (apache#6134)
  MINOR: Remove the InvalidTopicException handling in InternalTopicManager (apache#6167)
  [KAFKA-7024] Rocksdb state directory should be created before opening the DB (apache#6138)
  MINOR:: Fix typos (apache#6079)
* ak/trunk:
  MINOR: Update usage of deprecated API (apache#6146)
  KAFKA-4217: Add KStream.flatTransform (apache#5273)
  MINOR: Update Gradle to 5.1.1 (apache#6160)
  KAFKA-3522: Generalize Segments (apache#6170)
  Added quotes around the class path (apache#4469)
  KAFKA-7837: Ensure offline partitions are picked up as soon as possible when shrinking ISR (apache#6202)
  MINOR: In the MetadataResponse schema, ignorable should be a boolean
  KAFKA-7838: Log leader and follower end offsets when shrinking ISR (apache#6168)
  KAFKA-5692: Change PreferredReplicaLeaderElectionCommand to use Admin… (apache#3848)
  MINOR: clarify why suppress can sometimes drop tombstones (apache#6195)
  MINOR: Upgrade ducktape to 0.7.5 (apache#6197)
  MINOR: Improve IntegrationTestUtils documentation (apache#5664)
  MINOR: upgrade to jdk8 8u202
  KAFKA-7693; Fix SequenceNumber overflow in producer (apache#5989)
  KAFKA-7692; Fix ProducerStateManager SequenceNumber overflow (apache#5990)
  MINOR: update copyright year in the NOTICE file. (apache#6196)
  KAFKA-7793: Improve the Trogdor command line. (apache#6133)
* AK/trunk:
  fix typo (apache#5150)
  MINOR: Reduce replica.fetch.backoff.ms in ReassignPartitionsClusterTest (apache#5887)
  KAFKA-7766: Fail fast PR builds (apache#6059)
  KAFKA-7798: Expose embedded clientIds (apache#6107)
  KAFKA-7641; Introduce "group.max.size" config to limit group sizes (apache#6163)
  KAFKA-7433; Introduce broker options in TopicCommand to use AdminClient (KIP-377)
  MINOR: Fix some field definitions for ListOffsetReponse (apache#6214)
  KAFKA-7873; Always seek to beginning in KafkaBasedLog (apache#6203)
  KAFKA-7719: Improve fairness in SocketServer processors (KIP-402) (apache#6022)
  MINOR: fix checkstyle suppressions for generated RPC code to work on Windows
  KAFKA-7859: Use automatic RPC generation in LeaveGroups (apache#6188)
  KAFKA-7652: Part II; Add single-point query for SessionStore and use for flushing / getter (apache#6161)
  KAFKA-3522: Add RocksDBTimestampedStore (apache#6149)
  KAFKA-3522: Replace RecordConverter with TimestampedBytesStore (apache#6204)
* ak/trunk: (45 commits)
  KAFKA-7487: DumpLogSegments misreports offset mismatches (apache#5756)
  MINOR: improve JavaDocs about auto-repartitioning in Streams DSL (apache#6269)
  KAFKA-7935: UNSUPPORTED_COMPRESSION_TYPE if ReplicaManager.getLogConfig returns None (apache#6274)
  KAFKA-7895: Fix stream-time reckoning for suppress (apache#6278)
  KAFKA-6569: Move OffsetIndex/TimeIndex logger to companion object  (apache#4586)
  MINOR: add log indicating the suppression time (apache#6260)
  MINOR: Make info logs for KafkaConsumer a bit more verbose (apache#6279)
  KAFKA-7758: Reuse KGroupedStream/KGroupedTable with named repartition topics (apache#6265)
  KAFKA-7884; Docs for message.format.version should display valid values (apache#6209)
  MINOR: Save failed test output to build output directory
  MINOR: add test for StreamsSmokeTestDriver (apache#6231)
  MINOR: Fix bugs identified by compiler warnings (apache#6258)
  KAFKA-6474: Rewrite tests to use new public TopologyTestDriver [part 4] (apache#5433)
  MINOR: fix bypasses in ChangeLogging stores (apache#6266)
  MINOR: Make MockClient#poll() more thread-safe (apache#5942)
  MINOR: drop dbAccessor reference on close (apache#6254)
  KAFKA-7811: Avoid unnecessary lock acquire when KafkaConsumer commits offsets (apache#6119)
  KAFKA-7916: Unify store wrapping code for clarity (apache#6255)
  MINOR: Add missing Alter Operation to Topic supported operations list in AclCommand
  KAFKA-7921: log at error level for missing source topic (apache#6262)
  ...
* AK/trunk: (36 commits)
  KAFKA-7962: Avoid NPE for StickyAssignor (apache#6308)
  Address flakiness of CustomQuotaCallbackTest#testCustomQuotaCallback (apache#6330)
  KAFKA-7918: Inline generic parameters Pt. II: RocksDB Bytes Store and Memory LRU Caches (apache#6327)
  MINOR: fix parameter naming (apache#6316)
  KAFKA-7956 In ShutdownableThread, immediately complete the shutdown if the thread has not been started (apache#6218)
  MINOR: Refactor replica log dir fetching for improved logging (apache#6313)
  [TRIVIAL] Remove unused StreamsGraphNode#repartitionRequired (apache#6227)
  MINOR: Increase produce timeout to 120 seconds (apache#6326)
  KAFKA-7918: Inline generic parameters Pt. I: in-memory key-value store (apache#6293)
  MINOR: Fix line break issue in upgrade notes (apache#6320)
  KAFKA-7972: Use automatic RPC generation in SaslHandshake
  MINOR: Enable capture of full stack trace in StreamTask#process (apache#6310)
  KAFKA-7938: Fix test flakiness in DeleteConsumerGroupsTest (apache#6312)
  KAFKA-7937: Fix Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup (apache#6311)
  MINOR: Update docs to say 2.2 (apache#6315)
  KAFKA-7672 : force write checkpoint during StreamTask #suspend (apache#6115)
  KAFKA-7961; Ignore assignment for un-subscribed partitions (apache#6304)
  KAFKA-7672: Restoring tasks need to be closed upon task suspension (apache#6113)
  KAFKA-7864; validate partitions are 0-based (apache#6246)
  KAFKA-7492 : Updated javadocs for aggregate and reduce methods returning null behavior. (apache#6285)
  ...
* apache/trunk:
  KAFKA-7880:Naming worker thread by task id (apache#6275)
  improve some logging statements (apache#6078)
  KAFKA-7312: Change broker port used in testMinimumRequestTimeouts and testForceClose
  KAFKA-7997: Use automatic RPC generation in SaslAuthenticate
  KAFKA-8002; Log dir reassignment stalls if future replica has different segment base offset (apache#6346)
  KAFKA-3522: Add TimestampedKeyValueStore builder/runtime classes (apache#6152)
  HOTFIX: add igore import to streams_upgrade_test
  MINOR: ConsumerNetworkClient does not need to send the remaining requests when the node is not ready (apache#6264)
  KAFKA-7922: Return authorized operations in describe consumer group responses (KIP-430 Part-1)
  KAFKA-7918: Inline generic parameters Pt. III: in-memory window store (apache#6328)
  KAFKA-8012; Ensure partitionStates have not been removed before truncating. (apache#6333)
  KAFKA-8011: Fix for race condition causing concurrent modification exception (apache#6338)
  KAFKA-7912: Support concurrent access in InMemoryKeyValueStore (apache#6336)
  MINOR: Skip quota check when replica is in sync (apache#6344)
  HOTFIX: Change header back to http instead of https to path license header test (apache#6347)
  MINOR: fix release.py script (apache#6317)
  MINOR: Remove types from caching stores (apache#6331)
  MINOR: Improve logging for alter log dirs (apache#6302)
  MINOR: state.cleanup.delay.ms default is 600,000 ms (10 minutes). (apache#6345)
  MINOR: disable Streams system test for broker upgrade/downgrade (apache#6341)
* warn-apache-kafka/trunk: (41 commits)
  MINOR: Avoid double null check in KStream#transform() (apache#6429)
  KAFKA-7944: Improve Suppress test coverage (apache#6382)
  KAFKA-3522: add missing guards for TimestampedXxxStore (apache#6356)
  MINOR: Change Trogdor agent's cleanup executor to a cached thread pool (apache#6309)
  KAFKA-7976; Update config before notifying controller of unclean leader update (apache#6426)
  KAFKA-7801: TopicCommand should not be able to alter transaction topic partition count
  KAFKA-8091; Wait for processor shutdown before testing removed listeners (apache#6425)
  MINOR: Update delete topics zk path in assertion error messages
  KAFKA-7939: Fix timing issue in KafkaAdminClientTest.testCreateTopicsRetryBackoff
  KAFKA-7922: Return authorized operations in Metadata request response (KIP-430 Part-2)
  MINOR: Print usage when parse fails during console producer
  MINOR: fix Scala compiler warning (apache#6417)
  KAFKA-7288; Fix check in SelectorTest to wait for no buffered bytes (apache#6415)
  KAFKA-8065: restore original input record timestamp in forward() (apache#6393)
  MINOR: cleanup deprectaion annotations (apache#6290)
  KAFKA-3522: Add TimestampedWindowStore builder/runtime classes (apache#6173)
  KAFKA-8069; Fix early expiration of offsets due to invalid loading of expire timestamp (apache#6401)
  KAFKA-8070: Increase consumer startup timeout in system tests (apache#6405)
  KAFKA-8040: Streams handle initTransactions timeout (apache#6372)
  KAFKA-7980 - Fix timing issue in SocketServerTest.testConnectionRateLimit (apache#6391)
  ...
* apache/trunk:
  MINOR: Retain public constructors of classes from public API (apache#6455)
  KAFKA-8118; Ensure ZK clients are closed in tests, fix verification (apache#6456)
  KAFKA-7813: JmxTool throws NPE when --object-name is omitted
  KAFKA-8114: Wait for SCRAM credential propagation in DelegationTokenEndToEndAuthorizationTest (apache#6452)
  KAFKA-8111; Set min and max versions for Metadata requests (apache#6451)
  KAFKA-7855: Kafka Streams Maven Archetype quickstart fails to compile out of the box (apache#6194)
  MINOR: Update code to not use deprecated methods (apache#6434)
  MINOR: Update Trogdor ConnectionStressWorker status at the end of execution (apache#6445)
  KAFKA-8091; Use commitSync to check connection failure in listener update test (apache#6450)
  KAFKA-7027: Add an overload build method in scala (apache#6373)
  MINOR: Fix typos in LogValidator (apache#6449)
  KAFKA-7502: Cleanup KTable materialization logic in a single place (apache#6174)
  KAFKA-7730; Limit number of active connections per listener in brokers (KIP-402)
  KAFKA-8091; Remove unsafe produce from dynamic listener update test (apache#6443)
  MINOR: Fix JavaDocs warnings (apache#6435)
  MINOR: Better messaging for invalid fetch response (apache#6427)
  MINOR: Use Java 8 lambdas in KStreamImplTest (apache#6430)
* apache/trunk:
  MINOR: Improve logging around index files (apache#6385)
  KAFKA-7858: Automatically generate JoinGroup request/response
  KAFKA-8121; Shutdown ZK client expiry handler earlier during close (apache#6462)
  MINOR: Improve verification in flaky testPartitionReassignmentDuringDeleteTopic (apache#6460)
* apache/trunk: (23 commits)
  KAFKA-7986: Distinguish logging from different ZooKeeperClient instances (apache#6493)
  KAFKA-8102: Add an interval-based Trogdor transaction generator (apache#6444)
  MINOR: Fix misspelling in protocol documentation
  KAFKA-8150: Fix bugs in handling null arrays in generated RPC code (apache#6489)
  KAFKA-8014: Extend Connect integration tests to add and remove workers dynamically (apache#6342)
  MINOR: Remove line for testing repartition topic name (apache#6488)
  MINOR: add MacOS requirement to Streams docs
  MINOR: fix message protocol help text for ElectPreferredLeadersResult (apache#6479)
  MINOR: list-topics should not require topic param
  MINOR: Clean up ThreadCacheTest (apache#6485)
  MINOR: Avoid unnecessary collection copy in MetadataCache (apache#6397)
  KAFKA-8142: Fix NPE for nulls in Headers (apache#6484)
  KAFKA-7243: Add unit integration tests to validate metrics in Kafka Streams (apache#6080)
  MINOR: Add verification step for Streams archetype to Jenkins build (apache#6431)
  KAFKA-7819: Improve RoundTripWorker (apache#6187)
  KAFKA-7989: RequestQuotaTest should wait for quota config change before running tests (apache#6482)
  KAFKA-8098: Fix Flaky Test testConsumerGroups
  KAFKA-6958: Add new NamedOperation interface to enforce consistency in naming operations (apache#6409)
  MINOR: capture result timestamps in Kafka Streams DSL tests (apache#6447)
  MINOR: updated names for deprecated streams constants (apache#6466)
  ...
* apache/trunk:
  KAFKA-8030: Fix flaky tests in TopicCommandWithAdminClientTest
  fix compile error for example (apache#6526)
  MINOR: Comment spelling nit
  MINOR: Optimize ConnectionStressWorker
  KAFKA-8034: Use automatic RPC generation in DeleteTopics
  MINOR: Move KTable source topic for changelog to optimization framework (apache#6500)
  KAFKA-7502: Cleanup KTable materialization logic in a single place (doMapValues) (apache#6520)
  Cleanup KTableImpl#doTransformValues (apache#6519)
  MINOR: Streams input topic corrected (apache#6513)
  MINOR: WorkerUtils#abort: fix bug in abort logic (apache#6516)
  KAFKA-7502: Cleanup KTable materialization logic in a single place (filter) (apache#6453)
  MINOR: Fix some spelling corrections in comments (apache#6507)
  KAFKA-3522: Add RocksDBTimestampedSegmentedBytesStore (apache#6186)
  MINOR: Add 2.2.0 upgrade instructions (apache#6501)
* apache/trunk:
  MINOR: Add security considerations for remote JMX in Kafka docs (apache#6544)
  MINOR: Remove redundant access specifiers from metrics interfaces (apache#6527)
  MINOR: Correct KStream documentation (apache#6552)
  KAFKA-8013; Avoid underflow when reading a Struct from a partially correct buffer (apache#6340)
  KAFKA-8058: Fix ConnectClusterStateImpl.connectors() method (apache#6384)
  MINOR: Move common consumer tests out of abstract consumer class (apache#6548)
  KAFKA-8168; Add a generated ApiMessageType class
  KAFKA-7893; Refactor ConsumerBounceTest to reuse functionality from BaseConsumerTest (apache#6238)
  MINOR: Tighten up metadata upgrade test (apache#6531)
  KAFKA-8190; Don't update keystore modification time during validation (apache#6539)
  MINOR: Fixed a few warning in core and connects (apache#6545)
  KAFKA-7904; Add AtMinIsr partition metric and TopicCommand option (KIP-427)
  MINOR: fix throttling and status in ConnectionStressWorker
  KAFKA-8090: Use automatic RPC generation in ControlledShutdown
  KAFKA-6399: Remove Streams max.poll.interval override (apache#6509)
  KAFKA-8126: Flaky Test org.apache.kafka.connect.runtime.WorkerTest.testAddRemoveTask (apache#6475)
  HOTFIX: Update unit test for KIP-443
  KAFKA-7190: KIP-443; Remove streams overrides on repartition topics (apache#6511)
  KAFKA-8183: Add retries to WorkerUtils#verifyTopics (apache#6532)
  KAFKA-8181: Removed Avro topic from TOC on kafka (apache#6529)
Merge the open source code from
https://github.com/confluentinc/support-metrics-common
and https://github.com/confluentinc/support-metrics-client
into Confluent Community Kafka.

bin/kafka-server-start will now start an instance of SupportedKafka.

Disable source header validation and indentation validation for now,
since the proactive support files differ slightly in these regards.

Add a confluent-import-control.xml file to handle Confluent-specific
import control settings.

Fix the code to conform to checkstyle, and fix a few minor spotbugs
errors.  Remove aspect4j dependency and guava dependency in favor of
junit and the standard library.
Fix a bug where support-metrics-common tests could sometimes not find
the definition of the IntegrationTest annotation.

Fix a bug where FilterTest was using Properties#contains where
Properties#containsKey was appropriate.
Reviewers: Gwen Shapira <cshapi@gmail.com>
Reviewers: Bob Barrett <bob.barrett@confluent.io>
support-metrics-client should depend on the test sources from
support-metrics-common.

KafkaUtilitiesTest.scala is simply a Scala copy of a Java test, so
remove it.  This also fixes a problem where support-metrics-client and
support-metrics-common had diferent classes with the same name.

Port over MetricsReporterTest.java, MetricsToKafkaTest.java,
SupportedServerStartableTest.java, BasicCollectorTest.java,
CollectorFactoryTest.java from the old support-metrics-client
repository.  These were missed in the original conversion.

Reviewers: Dhruvil Shah <dhruvilshah05@gmail.com>
With the change to integrate support metrics in this repo, we should now expect the main class to be `SupportedKafka` instead of `kafka.Kafka`. This patch addresses system test failures.
ConfluentJenkins and others added 28 commits May 19, 2020 14:37
Reviewers: Ismael Juma <ismael@juma.me.uk>
We have updated gradle daemon heap memory to 2g. This PR is to increase the scalac heap size to 2g. This will make consistent memory settings.

Reviewers: Ismael Juma <ismael@juma.me.uk>
@agg111 agg111 closed this Jun 3, 2020
@agg111
Copy link
Copy Markdown
Contributor Author

agg111 commented Jun 3, 2020

Created by mistake, closing it.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.