2.0#7306

Closed

hw1992 wants to merge 348 commits into

trunkfrom

This pull request is big! We're only showing the most recent 250 commits

Commits on Jul 6, 2018

MINOR: Use FetchRequest v8 and ListOffsetRequest v3 in ReplicaFetcherThread (#5342)
ijuma
committed

Commits on Jul 17, 2018

Commits on Jul 19, 2018

MINOR: Update build.gradle and release.py to upload streams-scala_2.12 (#5368)
rajinisivaram
committed
KAFKA-7182: SASL/OAUTHBEARER client response missing %x01 seps (#5391)

rondagostino
authored and
rajinisivaram
committed

Commits on Jul 21, 2018

Commits on Jul 22, 2018

MINOR: Close ZooKeeperClient if waitUntilConnected fails during construction (#5411)

omkreddy
authored and
ijuma
committed

Commits on Jul 23, 2018

KAFKA-7193: Use ZooKeeper IP address in streams tests to avoid timeouts (#5414)
rajinisivaram
committed

Commits on Jul 24, 2018

Commits on Jul 25, 2018

MINOR: Add thread dumps if broker node cannot be stopped (#5373)

wicknicks
authored and
hachikuji
committed

Commits on Jul 26, 2018

Commits on Jul 28, 2018

Commits on Jul 30, 2018

KAFKA-7180; Fixing the flaky test testHWCheckpointWithFailuresSingleLogSegment

gitlw
authored and
lindong28
committed

Commits on Aug 1, 2018

Commits on Aug 2, 2018

Commits on Aug 3, 2018

Commits on Aug 6, 2018

MINOR: Fixed default streams state dir location. (#5441)

Malakhit
authored and
mjsax
committed
MINOR: fix Streams docs state.dir (#5465)
mjsax
committed

Commits on Aug 7, 2018

KAFKA-7250: fix transform function in scala DSL to accept TranformerSupplier (#5468)

mdziemianko
authored and
guozhangwang
committed
MINOR: Fix Streams scala format violations (#5472)

omkreddy
authored and
guozhangwang
committed
KAFKA-7225: Pretransform validated props

rayokota
authored and
ewencp
committed
MINOR: Fix minikdc cleanup in system tests (#5471)

wicknicks
authored and
hachikuji
committed
MINOR: System test for error handling and writes to DeadLetterQueue

wicknicks
authored and
ewencp
committed
MINOR: Add Scalafmt to Streams Scala API (#4965)

joan38
authored and
guozhangwang
committed

Commits on Aug 9, 2018

MINOR: Fixed log in Topology Builder. (#5477)

kamalcph
authored and
mjsax
committed
KAFKA-7250: switch scala transform to TransformSupplier (#5481)

vvcephei
authored and
guozhangwang
committed

Commits on Aug 12, 2018

KAFKA-7261: Record 1.0 for total metric when Count stat is used for rate (#5484)
rajinisivaram
committed

Commits on Aug 13, 2018

KAFKA-7164; Follower should truncate after every missed leader epoch change (#5436)

bob-barrett
authored and
hachikuji
committed

Commits on Aug 14, 2018

Commits on Aug 15, 2018

MINOR: close producer instance in AbstractJoinIntegrationTest (#5459)

omkreddy
authored and
mjsax
committed

Commits on Aug 20, 2018

Commits on Aug 21, 2018

KAFKA-7301: Fix streams Scala join ambiguous overload (#5502)

joan38
authored and
guozhangwang
committed

Commits on Aug 23, 2018

KAFKA-7316: Fix Streams Scala filter recursive call #5538

joan38
authored and
guozhangwang
committed
MINOR: Return correct instance of SessionWindowSerde (#5546)

kamalcph
authored and
guozhangwang
committed
KAFKA-7225; Corrected system tests by generating external properties file (#5489)

rhauch
authored and
hachikuji
committed

Commits on Aug 28, 2018

KAFKA-7128; Follower has to catch up to offset within current leader epoch to join ISR (#5557)

apovzner
authored and
hachikuji
committed
KAFKA-7242: Reverse xform configs before saving (KIP-297)

rayokota
authored and
ewencp
committed
KAFKA-7287: Set open ACL for old consumer znode path (#5503)

omkreddy
authored and
junrao
committed

Commits on Aug 29, 2018

KAFKA-7354; Fix IdlePercent and NetworkProcessorAvgIdlePercent metric

huxihx
authored and
lindong28
committed
MINOR: Fix streams Scala foreach recursive call (#5539)

joan38
authored and
guozhangwang
committed
MINOR: Fix streams Scala peek recursive call (#5566)

tedyu
authored and
guozhangwang
committed

Commits on Sep 1, 2018

Commits on Sep 3, 2018

MINOR: Use annotationProcessor instead of compile for JMH annotation processor

ijuma
authored and
lindong28
committed

Commits on Sep 4, 2018

MINOR: Update README to specify Gradle 4.6 as the minimum required version (#5606)

omkreddy
authored and
ijuma
committed

Commits on Sep 6, 2018

KAFKA-7353: Connect logs 'this' for anonymous inner classes

kevin-laff
authored and
ewencp
committed
MINOR: Enable ignored upgrade system tests 2.0 (#5614)

bbejeck
authored and
guozhangwang
committed

Commits on Sep 9, 2018

KAFKA-7385; Fix log cleaner behavior when only empty batches are retained (#5623)

dhruvilshah3
authored and
hachikuji
committed
KAFKA-7286; Avoid getting stuck loading large metadata records (#5500)

flavray
authored and
hachikuji
committed

Commits on Sep 11, 2018

KAFKA-7044; Fix Fetcher.fetchOffsetsByTimes and NPE in describe consumer group (#5627)

apovzner
authored and
hachikuji
committed
KAFKA-7386: streams-scala should not cache serdes (#5622)

vvcephei
authored and
guozhangwang
committed

Commits on Sep 13, 2018

MINOR: Use LATEST_1_1 instead of V_1_1_0 in quota_test (#5636)

apovzner
authored and
ijuma
committed

Commits on Sep 14, 2018

KAFKA-7280; Synchronize consumer fetch request/response handling (#5495)

rajinisivaram
authored and
hachikuji
committed

Commits on Sep 17, 2018

Commits on Sep 21, 2018

KAFKA-7216: Ignore unknown ResourceTypes while loading acl cache (#5673)

omkreddy
authored and
junrao
committed

Commits on Sep 25, 2018

MINOR: Upgrade to Jackson 2.9.7 (#5662)
ijuma
committed

Commits on Sep 27, 2018

KAFKA-7414; Out of range errors should never be fatal for follower (#5654)
hachikuji
committed

Commits on Sep 29, 2018

Commits on Oct 1, 2018

KAFKA-7459: Use thread-safe Pool for RequestMetrics.requestRateInternal (#5717)

hzxa21
authored and
ijuma
committed
KAFKA-7460: Fix Connect Values converter date format pattern

amitsela
authored and
ewencp
committed

Commits on Oct 4, 2018

Commits on Oct 5, 2018

Commits on Oct 9, 2018

KAFKA-7198: Enhance KafkaStreams start method javadoc. (#5763)

kamalcph
authored and
mjsax
committed

Commits on Oct 11, 2018

HOTFIX: Fix broken links (#5676)

bbejeck
authored and
guozhangwang
committed

Commits on Oct 20, 2018

KAFKA-7464; catch exceptions in "leaderEndpoint.close()" when shutting down ReplicaFetcherThread

hzxa21
authored and
lindong28
committed

Commits on Oct 21, 2018

MINOR: Less restrictive assertion in flaky BufferPool test (#5799)

colinhicks
authored and
ijuma
committed
KAFKA-7131: Update release script to generate announcement email text

Bibin Sebastian
authored and
ewencp
committed

Commits on Oct 22, 2018

KAFKA-7519 Clear pending transaction state when expiration fails (#5820)

BirdHowl
authored and
ijuma
committed

Commits on Oct 23, 2018

KAFKA-7299: Batch LeaderAndIsr requests for AutoLeaderRebalance (#5515)

huxi
authored and
junrao
committed

Commits on Oct 24, 2018

MINOR: Fix undefined variable in Connect test

rhauch
authored and
ewencp
committed
MINOR: Fix flaky assertion in ControllerIntegrationTest (#5829)

stanislavkozlovski
authored and
ijuma
committed

Commits on Oct 25, 2018

Commits on Oct 26, 2018

KAFKA-7532: Clean-up controller log when shutting down brokers (#5831)

stanislavkozlovski
authored and
ijuma
committed
MINOR: Increase low timeouts to help with test flakiness (#5841)

bbejeck
authored and
mjsax
committed
KAFKA-7534: Error in flush calling close may prevent underlying store from closing (#5833)

bbejeck
authored and
mjsax
committed

Commits on Oct 28, 2018

MINOR: Remove unintentional tilde character from kafka-run-class.bat script

florianhof
authored and
omkreddy
committed

Commits on Nov 3, 2018

KAFKA-7561: Increase stop_timeout_sec to make ConsoleConsumerTest pass (#5853)

gardnervickers
authored and
ijuma
committed

Commits on Nov 6, 2018

Commits on Nov 8, 2018

Commits on Nov 13, 2018

MINOR: Avoid logging connector configuration in Connect framework (#5868)

rhauch
authored and
hachikuji
committed

Commits on Nov 15, 2018

KAFKA-7584: StreamsConfig throws ClassCastException if max.in.flight.request.per.connect is specified as String (#5874)

mjsax
authored and
guozhangwang
committed

Commits on Nov 16, 2018

KAFKA-7576; Fix shutdown of replica fetcher threads (#5875)
rajinisivaram
committed

Commits on Nov 20, 2018

KAFKA-7536: Initialize TopologyTestDriver with non-null topic (#5923)
guozhangwang
committed

Commits on Nov 21, 2018

MINOR: increase system test kafka start timeout (#5934)

vvcephei
authored and
guozhangwang
committed

Commits on Nov 28, 2018

KAFKA-7620: Fix restart logic for TTLs in WorkerConfigTransformer

rayokota
authored and
ewencp
committed

Commits on Nov 29, 2018

KAFKA-7671: Stream-Global Table join should not reset repartition flag (#5959)

bbejeck
authored and
guozhangwang
committed

Commits on Nov 30, 2018

MINOR: Add logging to Connect SMTs

cyrusv
authored and
ewencp
committed

Commits on Dec 3, 2018

MINOR: improve QueryableStateIntegrationTest (#5987)
guozhangwang
committed

Commits on Dec 4, 2018

Commits on Dec 5, 2018

MINOR: Safe string conversion to avoid NPEs

cyrusv
authored and
ewencp
committed
KAFKA-7678: Avoid NPE when closing the RecordCollector (#5993)

jonathansantilli
authored and
mjsax
committed
KAFKA-6388; Recover from rolling an empty segment that already exists (#5986)

apovzner
authored and
hachikuji
committed

Commits on Dec 11, 2018

KAFKA-7443: OffsetOutOfRangeException in restoring state store from changelog topic when start offset of local checkpoint is smaller than that of changelog topic (#5946)

linyli001
authored and
mjsax
committed

Commits on Dec 13, 2018

KAFKA-7655 Metadata spamming requests from Kafka Streams under some circumstances, potential DOS (#5929)

Pasvaz
authored and
mjsax
committed

Commits on Dec 17, 2018

KAFKA-7616; Make MockConsumer only add entries to the partition map returned by poll() if there are any records to return

srdo
authored and
hachikuji
committed

Commits on Dec 20, 2018

MINOR: Streams broker down flaky test (#6041)

bbejeck
authored and
guozhangwang
committed
KAFKA-7759; Disable WADL output in the Connect REST API (#6051)

avocader
authored and
hachikuji
committed

Commits on Dec 22, 2018

MINOR: standby task test throughput too low 2.0 (#6062)

bbejeck
authored and
guozhangwang
committed

Commits on Dec 28, 2018

KAFKA-3832; Kafka Connect's JSON Converter never outputs a null value (#6027)

renatomefi
authored and
hachikuji
committed
MINOR: Improve exception messages in FileChannelRecordBatch (#6068)

flavray
authored and
hachikuji
committed

Commits on Jan 2, 2019

KAFKA-5503; Idempotent producer ignores shutdown while fetching ProducerId (#5881)

layfe
authored and
hachikuji
committed

Commits on Jan 8, 2019

KAFKA-7253; The returned connector type is always null when creating connector (#5470)

chia7712
authored and
hachikuji
committed

Commits on Jan 9, 2019

KAFKA-7799; Fix flaky test RestServerTest.testCORSEnabled (#6106)
hachikuji
committed

Commits on Jan 10, 2019

KAFKA-7741: Streams exclude javax dependency (#6121)

vvcephei
authored and
guozhangwang
committed

Commits on Jan 12, 2019

KAFKA-7741: streams-scala - document dependency workaround (#6125)

vvcephei
authored and
guozhangwang
committed

Commits on Jan 14, 2019

KAFKA-7503: Connect integration test harness

wicknicks
authored and
ewencp
committed

Commits on Jan 17, 2019

MINOR: Start Connect REST server in standalone mode to match distributed mode (KAFKA-7503 follow-up)

mageshn
authored and
ewencp
committed

Commits on Jan 21, 2019

MINOR: Handle case where connector status endpoints returns 404 (#6176)

wicknicks
authored and
mjsax
committed

Commits on Jan 22, 2019

MINOR: Cleanup handling of mixed transactional/idempotent records (#6172)
hachikuji
committed

Commits on Jan 23, 2019

KAFKA-5117: Stop resolving externalized configs in Connect REST API

C0urante
authored and
ewencp
committed

Commits on Jan 24, 2019

KAFKA-6833; Producer should await metadata for unknown partitions (#6073) (#6154)

rayokota
authored and
hachikuji
committed

Commits on Jan 25, 2019

KAFKA-7692; Fix ProducerStateManager SequenceNumber overflow (#5990)

mingaliu
authored and
hachikuji
committed
KAFKA-7693; Fix SequenceNumber overflow in producer (#5989)

mingaliu
authored and
hachikuji
committed
MINOR: upgrade to jdk8 8u202

Jarek Rudzinski
authored and
ewencp
committed

Commits on Feb 1, 2019

KAFKA-7873; Always seek to beginning in KafkaBasedLog (#6203)

rhauch
authored and
hachikuji
committed

Commits on Feb 5, 2019

MINOR: Upgrade ducktape to 0.7.5 (#6197)

kkonstantine
authored and
ewencp
committed
KAFKA-7834: Extend collected logs in system test services to include heap dumps

kkonstantine
authored and
ewencp
committed

Commits on Feb 11, 2019

KAFKA-7741: Reword Streams dependency workaround docs (#6207)

vvcephei
authored and
guozhangwang
committed

Commits on Feb 12, 2019

KAFKA-7897; Do not write epoch start offset for older message format versions (#6253)
hachikuji
authored

Commits on Feb 14, 2019

MINOR: Make MockClient#poll() more thread-safe (#5942)

stanislavkozlovski
authored and
hachikuji
committed

Commits on Feb 19, 2019

KAFKA-7799; Use httpcomponents-client in RestServerTest.

avocader
authored and
gwenshap
committed

Commits on Feb 20, 2019

MINOR: Add check all topics created check streams broker bounce test (2.0) (#6241)
bbejeck
authored

Commits on Feb 22, 2019

KAFKA-7959; Delete leader epoch cache files with old message format versions (#6298)

stanislavkozlovski
authored and
hachikuji
committed

Commits on Feb 26, 2019

MINOR: Increase produce timeout to 120 seconds (#6326)

wicknicks
authored and
rhauch
committed

Commits on Feb 27, 2019

KAFKA-7990: Close streams at the end in KafkaStreamsTest (#6334)
guozhangwang
authored

Commits on Feb 28, 2019

MINOR: disable Streams system test for broker upgrade/downgrade (#6341)

guozhangwang
authored and
mjsax
committed
MINOR: state.cleanup.delay.ms default is 600,000 ms (10 minutes). (#6345)

cwildman
authored and
mjsax
committed

Commits on Mar 1, 2019

Commits on Mar 4, 2019

Commits on Mar 7, 2019

KAFKA-8061; Handle concurrent ProducerId reset and call to Sender thread shutdown (#6388)

omkreddy
authored and
hachikuji
committed

Commits on Mar 9, 2019

KAFKA-8065: restore original input record timestamp in forward() (#6393)
mjsax
committed

Commits on Mar 11, 2019

KAFKA-8040: Streams handle initTransactions timeout (#6416)

vvcephei
authored and
bbejeck
committed

Commits on Mar 16, 2019

KAFKA-7855: Kafka Streams Maven Archetype quickstart fails to compile out of the box (#6194)

aurlien
authored and
mjsax
committed

Commits on Mar 19, 2019

MINOR: Improve logging around index files (#6385)

bob-barrett
authored and
hachikuji
committed

Commits on Apr 3, 2019

KAFKA-8126: Flaky Test org.apache.kafka.connect.runtime.WorkerTest.testAddRemoveTask (#6475)

adoroszlai
authored and
rhauch
committed

Commits on Apr 7, 2019

Commits on Apr 13, 2019

KAFKA-8213 - Fix typo in Streams Dev Guide (#6574)

londoncalling
authored and
mjsax
committed
KAFKA-8212 DOCS (kafka) - Fix Maven artifacts table from cutting off text (#6576)

londoncalling
authored and
mjsax
committed

Commits on Apr 16, 2019

Commits on Apr 17, 2019

MINOR: code cleanup TopologyTestDriverTest (#6504)
mjsax
committed

Commits on Apr 18, 2019

Commits on Apr 19, 2019

HOTFIX: remove unused import (#6605)
mjsax
authored

Commits on Apr 22, 2019

KAFKA-8277: Fix NPEs in several methods of ConnectHeaders (#6550)

sortega
authored and
rhauch
committed

Commits on Apr 23, 2019

Commits on Apr 24, 2019

KAFKA-8227 DOCS Fixed missing links duality of streams tables (#6625)

londoncalling
authored and
bbejeck
committed

Commits on Apr 25, 2019

MINOR: Do not log retriable offset commit exceptions as errors (#5904)

t3hnar
authored and
hachikuji
committed

Commits on May 1, 2019

KAFKA-8066; Always close the sensors in Selector.close() (#6402)

hzxa21
authored and
hachikuji
committed

Commits on May 4, 2019

KAFKA-8306; Initialize log end offset accurately when start offset is non-zero (#6652)

dhruvilshah3
authored and
hachikuji
committed

Commits on May 7, 2019

KAFKA-8304: Fix registration of Connect REST extensions (#6651)

C0urante
authored and
rhauch
committed

Commits on May 9, 2019

KAFKA-6789; Handle retriable group errors in AdminClient API (#5578)

omkreddy
authored and
hachikuji
committed

Commits on May 10, 2019

MINOR: Remove header and key/value converter config value logging (#6660)

C0urante
authored and
rhauch
committed
KAFKA-8348: Fix KafkaStreams JavaDocs (#6707)

Lifei Chen
authored and
mjsax
committed
KAFKA-8352 : Fix Connect System test failure 404 Not Found (#6713)

mageshn
authored and
rhauch
committed

Commits on May 11, 2019

Commits on May 13, 2019

KAFKA-8335; Clean empty batches when sequence numbers are reused (#6715)
hachikuji
committed

Commits on May 14, 2019

KAFKA-8363: Fix parsing bug for config providers (#6726)

C0urante
authored and
rhauch
committed

Commits on May 15, 2019

KAFKA-8320 : fix retriable exception package for source connectors (#6675)

mageshn
authored and
rhauch
committed

Commits on May 16, 2019

MINOR: Enable console logs in Connect tests (#6745)

kkonstantine
authored and
rhauch
committed

Commits on May 18, 2019

KAFKA-7773; Add end to end system test relying on verifiable consumer (#6070)
hachikuji
committed

Commits on May 20, 2019

KAFKA-8290: Close producer for zombie task (#6636)
bbejeck
committed

Commits on May 29, 2019

MINOR: Fix red herring when ConnectDistributedTest.test_bounce fails. (#6838)

avocader
authored and
rhauch
committed

Commits on May 30, 2019

KAFKA-8418: Wait until REST resources are loaded when starting a Connect Worker. (#6840)

avocader
authored and
rhauch
committed

Commits on Jun 4, 2019

KAFKA-8404: Add HttpHeader to RestClient HTTP Request and Connector REST API (#6791)

haidangdam
authored and
rhauch
committed

Commits on Jun 8, 2019

Commits on Jun 10, 2019

KAFKA-7315 DOCS update TOC internal links serdes all versions (#6875)

londoncalling
authored and
mjsax
committed

Commits on Jun 11, 2019

MINOR: Increase timeouts to 30 seconds (#6852)
bbejeck
committed

Commits on Jun 18, 2019

MINOR: Fix system test logic to handle duplicates between and (#6949)

stanislavkozlovski
authored and
omkreddy
committed

Commits on Jun 19, 2019

KAFKA-8564; Fix NPE on deleted partition dir when no segments remain (#6968)

mimaison
authored and
hachikuji
committed

Commits on Jun 21, 2019

Commits on Jun 22, 2019

MINOR: Add missing Alter Operation to Topic supported operations list in AclCommand
omkreddy
committed

Commits on Jul 8, 2019

MINOR: Split at first occurrence of '=' in kafka.py props parsing (#5549) (#7042)

kkonstantine
authored and
cmccabe
committed

Commits on Jul 12, 2019

Fixes #8198 KStreams testing docs use non-existent method pipe (#6678)

ouertani
authored and
bbejeck
committed
KAFKA-6605: Fix NPE in Flatten when optional Struct is null (#5705)

mihbor
authored and
rhauch
committed
KAFKA-7157: Fix handling of nulls in TimestampConverter (#7070)

rayokota
authored and
rhauch
committed

Commits on Aug 6, 2019

KAFKA-8736: Streams performance improvement, use isEmpty() rather than size() == 0 (#7164)

mjarvie
authored and
mjsax
committed

Commits on Aug 8, 2019

KAFKA-8602: Backport bugfix for standby task creation (#7146)

cadonna
authored and
mjsax
committed

Commits on Aug 11, 2019

KAFKA-8550: Fix plugin loading of aliased converters in Connect (#6959)

C0urante
authored and
rhauch
committed

Commits on Aug 13, 2019

KAFKA-8774: Regex can be found anywhere in config value (#7197)

wicknicks
authored and
rhauch
committed
KAFKA-7941: Catch TimeoutException in KafkaBasedLog worker thread (#6283)

pgwhalen
authored and
rhauch
committed

Commits on Aug 25, 2019

KAFKA-8586: Fail source tasks when producers fail to send records (#6993)

C0urante
authored and
rhauch
committed

Commits on Sep 4, 2019

KAFKA-8861 Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic (#7281)

chia7712
authored and
bbejeck
committed

Commits on Sep 9, 2019

KAFKA-8816: Make offsets immutable to users of RecordCollector.offsets (#7223)

cpettitt-confluent
authored and
guozhangwang
committed

Commits on Sep 13, 2019

HOTFIX: fix compile error in 2.0 branch (#7329)

mjsax
authored and
rhauch
committed

Commits on Sep 18, 2019

KAFKA-8913: Document topic based configs & ISR settings for Streams apps (#7346)

vinothchandar
authored and
mjsax
committed

Commits on Oct 3, 2019

KAFKA-8523 Enabling InsertField transform to be used with tombstone events (#6914)

gunnarmorling
authored and
rhauch
committed
KAFKA-6684: Support casting Connect values with bytes schema to string

amitsela
authored and
rhauch
committed
KAFKA-6290: Support casting from logical types in cast transform (#7371)

ncliang
authored and
rhauch
committed

Commits on Oct 4, 2019

KAFKA-8974: Trim whitespaces in topic names in sink connector configs (#7442)

mageshn
authored and
rhauch
committed

Commits on Oct 15, 2019

KAFKA-9014: Fix AssertionError when SourceTask.poll returns an empty list (#7491)

kkonstantine
authored and
rhauch
committed

Commits on Oct 16, 2019

KAFKA-8945/KAFKA-8947 backport (#7533)

C0urante
authored and
rhauch
committed

Commits on Oct 17, 2019

KAFKA-8340, KAFKA-8819: Use PluginClassLoader while statically initializing plugins (#7315)

gharris1727
authored and
rhauch
committed

Commits on Nov 20, 2019

KAFKA-9051: Prematurely complete source offset read requests for stopped tasks (#7532)

C0urante
authored and
rhauch
committed

Commits on Nov 21, 2019

KAFKA-1714: Fix gradle wrapper bootstrapping (#6031)

granthenke
authored and
ijuma
committed
MINOR: Update gradle wrapper
ijuma
committed