Update#1

Merged

egor-ryashin merged 1847 commits into

egor-ryashin:trunkfrom

Aug 13, 2019

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

Commits on May 23, 2019

KAFKA-8407: Fix validation of class and list configs in connector client overrides (#6789)

C0urante
authored and
rhauch
committed
KAFKA-8371: Remove dependence on ReplicaManager from Partition (#6705)
hachikuji
authored
MINOR: Add 2.0, 2.1 and 2.2 to broker and client compat tests

ijuma
authored and
gwenshap
committed

Commits on May 27, 2019

KAFKA-8437; Await node api versions before checking if offset validation is possible (#6823)
hachikuji
authored
KAFKA-8219: add doc changes for static membership release (#6790)

Boyang Chen
authored and
guozhangwang
committed

Commits on May 28, 2019

Commits on May 29, 2019

Commits on May 30, 2019

[MINOR] Improve docs for Global Store operations (#6803)

ableegoldman
authored and
bbejeck
committed
MINOR: Extend RocksDB section of Memory Management Docs (#6793)

ableegoldman
authored and
bbejeck
committed
KAFKA-8187: Add wait time for other thread in the same jvm to free the locks (#6818)

Lifei Chen
authored and
bbejeck
committed
KAFKA-8429; Handle offset change when OffsetForLeaderEpoch inflight (#6811)
hachikuji
authored
KAFKA-6455: Update integration tests to verify result timestamps (#6751)
mjsax
authored
KAFKA-8418: Wait until REST resources are loaded when starting a Connect Worker. (#6840)

avocader
authored and
rhauch
committed
KAFKA-8155: Add 2.1.1 release to system tests (#6596)
mjsax
authored
KAFKA-8389: Remove redundant bookkeeping from MockProcessor (#6761)
guozhangwang
authored
KAFKA-8199: Implement ValueGetter for Suppress (#6781)

vvcephei
authored and
guozhangwang
committed
MINOR:Replace duplicated code with common function in utils (#6819)

Lifei Chen
authored and
mjsax
committed

Commits on May 31, 2019

KAFKA-6958: Overload KStream methods to allow to name operation name using the new Named class (#6411)

fhussonnois
authored and
bbejeck
committed

Commits on Jun 1, 2019

MINOR: Reordering the props modification with configs construction
guozhangwang
authored

Commits on Jun 2, 2019

KAFKA-8446: Kafka Streams restoration crashes with NPE when the record value is null (#6842)

Boyang Chen
authored and
guozhangwang
committed
KAFKA-8463: Fix redundant reassignment of tasks when leader worker leaves (#6859)

kkonstantine
authored and
rhauch
committed

Commits on Jun 3, 2019

KAFKA-8425: Fix for correctly handling immutable maps (KIP-421 bug) (#6795)

tadsul
authored and
rajinisivaram
committed
KAFKA-8426; Fix for keeping the ConfigProvider configs consistent with KIP-297 (#6750)

tadsul
authored and
rajinisivaram
committed
KAFKA-8449: Restart tasks on reconfiguration under incremental cooperative rebalancing (#6850)

kkonstantine
authored and
rhauch
committed
KAFKA-8475: Temporarily restore SslFactory.sslContext() helper

rhauch
authored and
cmccabe
committed
KAFKA-8383; Integration tests for unclean `electLeaders` (#6857)

jsancio
authored and
hachikuji
committed
KAFKA-6819: Pt. 1 - Refactor thread-level Streams metrics (#6631)

cadonna
authored and
guozhangwang
committed
KAFKA-8473: Adjust Connect system tests for incremental cooperative rebalancing (#6872)

kkonstantine
authored and
rhauch
committed
HOTFIX: Allow multi-batches for old format and no compression (#6871)
guozhangwang
authored

Commits on Jun 4, 2019

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

haidangdam
authored and
rhauch
committed
KAFKA-8155: Add 2.2.0 release to system tests (#6597)
mjsax
authored
KAFKA 8311: better handle timeout exception on Stream thread (#6662)

Boyang Chen
authored and
guozhangwang
committed
KAFKA-4893; Fix deletion and moving of topics with long names

cmccabe
authored and
gwenshap
committed
Improve logging in the consumer for epoch updates (#6879)
mumrah
authored
MINOR: Update docs to say 2.3 (#6881)
cmccabe
authored

Commits on Jun 5, 2019

Commits on Jun 6, 2019

Commits on Jun 7, 2019

MINOR: Fixed compiler warnings in LogManagerTest (#6897)

Boyang Chen
authored and
guozhangwang
committed
KAFKA-8384; Leader election command integration tests (#6880)

jsancio
authored and
hachikuji
committed
KAFKA-8461: Wait for follower to join the ISR in testUncleanLeaderElectionDisabled Test
omkreddy
committed
MINOR: Increase timeout for flaky ResetConsumerGroupOffsetTest (#6900)

hachikuji
authored and
omkreddy
committed
KAFKA-8003; Fix flaky testFencingOnTransactionExpiration

hachikuji
authored and
gwenshap
committed
KAFKA-8331: stream static membership system test (#6877)

Boyang Chen
authored and
bbejeck
committed
KAFKA-8499: ensure java is in PATH for ducker system tests (#6898)

lbradstreet
authored and
cmccabe
committed
MINOR: Lower producer throughput in flaky upgrade system test

hachikuji
authored and
gwenshap
committed
MINOR: Fix race condition on shutdown of verifiable producer

hachikuji
authored and
gwenshap
committed

Commits on Jun 10, 2019

Commits on Jun 11, 2019

Commits on Jun 12, 2019

MINOR: Remove integration package prefix from ConsumerTopicCreationTest (#6916)

gardnervickers
authored and
omkreddy
committed
KAFKA-8514: Move the scala-java8-compat dependency from clients to core (#6910)

agavra
authored and
ijuma
committed
MINOR: Remove uncommitted code (#6919)

highluck
authored and
mumrah
committed
KAFKA-8500; Static member rejoin should always update member.id (#6899)

Boyang Chen
authored and
hachikuji
committed
MINOR: Seal the HostedPartition enumeration (#6917)

jsancio
authored and
hachikuji
committed
KAFKA-8483/KAFKA-8484; Ensure safe handling of producerId resets (#6883)
hachikuji
authored
KAFKA-8262, KAFKA-8263: Fix flaky test `MetricsIntegrationTest` (#6922)

cadonna
authored and
guozhangwang
committed
MINOR: add group coordinator test coverage (#6926)

Boyang Chen
authored and
guozhangwang
committed

Commits on Jun 13, 2019

KAFKA-8452: Compressed BufferValue (#6848)

vvcephei
authored and
bbejeck
committed
MINOR: Refactor `MetricsIntegrationTest` (#6930)

cadonna
authored and
bbejeck
committed

Commits on Jun 16, 2019

MINOR: fix some warnings in the broker

cmccabe
authored and
gwenshap
committed
MINOR: Fix expected output in Streams quickstart

vahidhashemian
authored and
gwenshap
committed

Commits on Jun 17, 2019

KAFKA-8457; Move `Log' reference from `Replica` into `Partition` (#6841)

soondenana
authored and
hachikuji
committed
KAFKA-7853: Refactor coordinator config (#6854)

Boyang Chen
authored and
guozhangwang
committed
KAFKA-8539; Add group.instance.id to Subscription (#6936)

Boyang Chen
authored and
hachikuji
committed
HOTFIX: Fix optional import in ConsumerCoordinator (#6953)

Boyang Chen
authored and
hachikuji
committed
MINOR: Simplify controller election utilities (#6944)
hachikuji
authored
KAFKA-6958: Overload KTable methods to allow to name operation name using the new Named class (#6412)

fhussonnois
authored and
bbejeck
committed

Commits on Jun 18, 2019

MINOR: rename subscription construction function (#6954)

Boyang Chen
authored and
guozhangwang
committed
MINOR: Update docs for KIP-415 (#6958)

kkonstantine
authored and
rhauch
committed
KAFKA-8448: Cancel PeriodicProducerExpirationCheck when closing a Log instance (#6847)

jolshan
authored and
cmccabe
committed
MINOR: fix consumer group failure message typo (#6962)

Boyang Chen
authored and
guozhangwang
committed

Commits on Jun 19, 2019

KAFKA-8559: Allocate ArrayList with correct size in PartitionStates (#6964)

wenhoujx
authored and
ijuma
committed
KAFKA-8452: Compressed BufferValue review follow-up (#6940)

vvcephei
authored and
bbejeck
committed
KAFKA-8564; Fix NPE on deleted partition dir when no segments remain (#6968)

mimaison
authored and
hachikuji
committed

Commits on Jun 20, 2019

MINOR: Fix Partition::toString method (#6971)

soondenana
authored and
hachikuji
committed
KAFKA-8569: integrate warning message under static membership (#6972)

Boyang Chen
authored and
guozhangwang
committed

Commits on Jun 21, 2019

Commits on Jun 22, 2019

Commits on Jun 23, 2019

Commits on Jun 25, 2019

HOTFIX: removed extra footnote (#6996)

ableegoldman
authored and
guozhangwang
committed
MINOR: add unit test for Utils.murmur2 (#5926)

natemurthy
authored and
omkreddy
committed
KAFKA-8390: Use automatic RPC generation in CreateDelegationToken (#6828)

mimaison
authored and
omkreddy
committed
MINOR: Fix flaky test case for compact/delete topics (#6975)
hachikuji
authored
MINOR: Fix for typos in processor-api.html (#6961)

seprokof
authored and
bbejeck
committed
Minor: code enhancment (#6999)

khaireddine120
authored and
bbejeck
committed

Commits on Jun 27, 2019

Commits on Jun 28, 2019

KAFKA-8356: add static membership info to round robin assignor (#6815)

Boyang Chen
authored and
guozhangwang
committed
KAFKA-8538 (part of KIP-345): add group.instance.id to DescribeGroup (#6957)

Boyang Chen
authored and
guozhangwang
committed
MINOR: Add compatibility tests for 2.3.0 (#6995)
cmccabe
authored
MINOR: add upgrade text (#7013)
cmccabe
authored
remove cs (#6950)

Boyang Chen
authored and
bbejeck
committed

Commits on Jun 29, 2019

KAFKA-8542; Cache transaction first offset metadata on follower (#6943)
hachikuji
authored

Commits on Jul 1, 2019

MINOR: Assert ExecutionException details in testCreatePartitions (#7017)
ijuma
authored

Commits on Jul 2, 2019

Commits on Jul 3, 2019

Commits on Jul 4, 2019

Commits on Jul 5, 2019

MINOR: Remove zkclient dependency (#7036)
ijuma
authored

Commits on Jul 8, 2019

MINOR: improve RocksDBConfigSetter docs (#7009)

ableegoldman
authored and
bbejeck
committed
MINOR: A few cleanups and compiler warning fixes (#6986)

dongjinleekr
authored and
hachikuji
committed

Commits on Jul 9, 2019

KAFKA-8591; WorkerConfigTransformer NPE on connector configuration reloading (#6991)

nachomdo
authored and
hachikuji
committed
MINOR: Fixes AK config typos (#7046)

joel-hamill
authored and
omkreddy
committed
KAFKA-3333: Adds RoundRobinPartitioner with tests (#6771)

mmanna-sapfgl
authored and
cmccabe
committed

Commits on Jul 10, 2019

Commits on Jul 11, 2019

Commits on Jul 12, 2019

KAFKA-8643; Bring back public MemberDescription constructor (#7060)

Boyang Chen
authored and
hachikuji
committed
KAFKA-5998: fix checkpointableOffsets handling (#7030)

vvcephei
authored and
bbejeck
committed
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
MINOR: Create a new topic for each test for flaky RegexSourceIntegrationTest (#6853)
bbejeck
authored
HOT FIX: close RocksDB objects in correct order (#7076)

ableegoldman
authored and
mjsax
committed
MINOR: Use dynamic port in `RestServerTest` (#7079)
hachikuji
authored

Commits on Jul 13, 2019

KAFKA-8614; Consistent naming for IncrementalAlterConfig and AlterConfig responses (#7022)

bob-barrett
authored and
hachikuji
committed
MINOR: Refactor admin client helpers for checking leader and ISR (#7074)

jsancio
authored and
hachikuji
committed

Commits on Jul 15, 2019

KAFKA-8602: Fix bug in stand-by task creation (#7008)

cadonna
authored and
bbejeck
committed
KAFKA-8620: fix NPE due to race condition during shutdown while rebalancing (#7021)

Boyang Chen
authored and
mjsax
committed
KAFKA-8637: WriteBatch objects leak off-heap memory (#7050)

ableegoldman
authored and
guozhangwang
committed

Commits on Jul 16, 2019

Commits on Jul 17, 2019

Commits on Jul 18, 2019

KAFKA-8670; Fix exception for kafka-topics.sh --describe without --topic mentioned (#7094)

Tirtha Chatterjee
authored and
hachikuji
committed
KAFKA-8615: Change to track partition time breaks TimestampExtractor (#7054)

ableegoldman
authored and
guozhangwang
committed
KAFKA-8635; Skip client poll in Sender loop when no request is sent (#7085)

bob-barrett
authored and
hachikuji
committed

Commits on Jul 20, 2019

KAFKA-8435: replace delete groups request/response with automated protocol (#6860)

Boyang Chen
authored and
cmccabe
committed

Commits on Jul 22, 2019

MINOR: kafkatest - adding whitelist for interbroker sasl configs (#7093)

brianbushree
authored and
rajinisivaram
committed
KAFKA-8454; Add Java AdminClient Interface (KIP-476) (#7087)

big-andy-coates
authored and
hachikuji
committed
KAFKA-8678; Fix leave group protocol bug in throttling and error response (#7101)

Boyang Chen
authored and
hachikuji
committed

Commits on Jul 23, 2019

KAFKA-8526; Fallback to other log dirs after getOrCreateLog failure (#6969)

soarez
authored and
hachikuji
committed
KAFKA-8696: clean up Sum/Count/Total metrics (#7057)

vvcephei
authored and
guozhangwang
committed

Commits on Jul 25, 2019

MINOR: Ensure in-memory metadata is removed before physical deletion of segment (#7106)

dhruvilshah3
authored and
junrao
committed
KAFKA-8179: add public ConsumerPartitionAssignor interface (#7108)

ableegoldman
authored and
guozhangwang
committed

Commits on Jul 26, 2019

KAFKA-8715; Fix buggy reliance on state timestamp in static member.id generation (#7116)

Boyang Chen
authored and
hachikuji
committed

Commits on Jul 27, 2019

KAFKA-8221; Add batch leave group request (#6714)

Boyang Chen
authored and
hachikuji
committed

Commits on Jul 28, 2019

Commits on Jul 29, 2019

Commits on Jul 30, 2019

KAFKA-8640; Use generated classes in OffsetFetch request and response (#7062)

Boyang Chen
authored and
hachikuji
committed
KAFKA-8442; Include ISR in Metadata response even if there is no leader (#6836)

huxi
authored and
hachikuji
committed
KAFKA-8717; Reuse cached offset metadata when reading from log (#7081)
hachikuji
authored
MINOR: Refactor abstractConfig#configuredInstance (#7129)
guozhangwang
authored

Commits on Jul 31, 2019

Commits on Aug 1, 2019

KAFKA-8456: Stabilize flaky StoreUpgradeIntegrationTest (#6941)
mjsax
authored
MINOR: Fix wrong debug log message (#7137)

cadonna
authored and
mjsax
committed
KAFKA-8601: Implement KIP-480: Sticky Partitioning for keyless records (#6997)

jolshan
authored and
cmccabe
committed

Commits on Aug 3, 2019

Commits on Aug 4, 2019

Commits on Aug 6, 2019

Minor: Refactor methods to add metrics to sensor in `StreamsMetricsImpl` (#7161)

cadonna
authored and
guozhangwang
committed
KAFKA-8736: Streams performance improvement, use isEmpty() rather than size() == 0 (#7164)

mjarvie
authored and
mjsax
committed
MINOR: some small style fixes to RoundRobinPartitioner

cmccabe
authored and
gwenshap
committed

Commits on Aug 7, 2019

Commits on Aug 8, 2019

Commits on Aug 11, 2019

Commits on Aug 12, 2019

MINOR: Remove Utils.notNull, use Objects.requireNonNull instead (#7194)

ijuma
authored and
vahidhashemian
committed
MINOR: Format AdminUtils::assignReplicasToBrokers java documentation (#7173)

soondenana
authored and
hachikuji
committed
MINOR: Clean up the sticky partitioner code a bit (#7151)

jolshan
authored and
cmccabe
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