Code

Upgrade Clients Compatibility to v0.10#1

Code

Open

manderson202 wants to merge 159 commits intomapr:trunkmapr/kafka:trunkfrom manderson202:0100-maprmanderson202/kafka:0100-maprCopy head branch name to clipboard

+2,865-3,840

Commits

Commits on Nov 7, 2015

• Changing version to 0.9.0.0

  gwenshap

  committed
  7710b36

  Copy full SHA for 7710b36

Commits on Nov 8, 2015

• KAFKA-2723: new consumer exception cleanup (0.9.0)

  Show description for 27d44af
  

  hachikuji

  authored and

  guozhangwang

  committed
  27d44af

  Copy full SHA for 27d44af

• HOTFIX: fix group coordinator edge cases around metadata storage callback (0.9.0)

  Show description for 32cd3e3
  

  hachikuji

  authored and

  guozhangwang

  committed
  32cd3e3

  Copy full SHA for 32cd3e3

Commits on Nov 9, 2015

• KAFKA-2480: Handle retriable and non-retriable exceptions thrown by sink tasks.

  Show description for 1fd79f5
  

  ewencp

  authored and

  gwenshap

  committed
  1fd79f5

  Copy full SHA for 1fd79f5

• KAFKA-2773; 0.9.0 branch)Fixed broken vagrant provision scripts for static zk/broker cluster

  Show description for 4801322
  

  Geoff Anderson

  authored and

  gwenshap

  committed
  4801322

  Copy full SHA for 4801322

• KAFKA-2774: Rename Copycat to Kafka Connect

  Show description for 417e283
  

  ewencp

  authored and

  gwenshap

  committed
  417e283

  Copy full SHA for 417e283

• KAFKA-2779; Close SSL socket channel on remote connection close

  Show description for 02fbdaa
  

  rajinisivaram

  authored and

  junrao

  committed
  02fbdaa

  Copy full SHA for 02fbdaa

• KAFKA-2781; Only require signing artifacts when uploading archives.

  Show description for fdefef9
  

  ewencp

  authored and

  junrao

  committed
  fdefef9

  Copy full SHA for fdefef9

• KAFKA-2776: Fix lookup of schema conversion cache size in JsonConverter.

  Show description for 7471394
  

  ewencp

  authored and

  gwenshap

  committed
  7471394

  Copy full SHA for 7471394

• HOTFIX: bug updating cache when loading group metadata

  Show description for 3aa3e85
  

  hachikuji

  authored and

  guozhangwang

  committed
  3aa3e85

  Copy full SHA for 3aa3e85

• KAFKA-2775: Move exceptions into API package for Kafka Connect.

  Show description for e627558
  

  ewencp

  authored and

  gwenshap

  committed
  e627558

  Copy full SHA for e627558

• KAFKA-2778: Use zero loss settings by default for Connect source producers.

  Show description for 4069011
  

  ewencp

  authored and

  gwenshap

  committed
  4069011

  Copy full SHA for 4069011

• KAFKA-2782: Fix KafkaBasedLogTest assertion and move it to the main test thread.

  Show description for 0d2fdfa
  

  ewencp

  authored and

  gwenshap

  committed
  0d2fdfa

  Copy full SHA for 0d2fdfa

• KAFKA-2258: add failover to mirrormaker test

  Show description for f22ea29
  

  Geoff Anderson

  authored and

  gwenshap

  committed
  f22ea29

  Copy full SHA for f22ea29

• KAFKA-2783; Drop outdated hadoop contrib modules

  Show description for e176fcc
  

  granthenke

  authored and

  gwenshap

  committed
  e176fcc

  Copy full SHA for e176fcc

• KAFKA-2674: clarify onPartitionsRevoked behavior

  Show description for 0977c03
  

  hachikuji

  authored and

  guozhangwang

  committed
  0977c03

  Copy full SHA for 0977c03

• MINOR: remove old producer in config sections to align with APIs

  Show description for 2e20898
  

  guozhangwang

  authored and

  gwenshap

  committed
  2e20898

  Copy full SHA for 2e20898

• MINOR: Improve exception message that gets thrown for non-existent group

  Show description for a8b263c
  

  Ashish Singh

  authored and

  guozhangwang

  committed
  a8b263c

  Copy full SHA for a8b263c

• KAFKA-2785; Include Kafka Connect jars in releaseTarGz.

  Show description for c258868
  

  ewencp

  authored and

  junrao

  committed
  c258868

  Copy full SHA for c258868

Commits on Nov 10, 2015

• MINOR: remove Kafka Streams in 0.9.0

  Show description for 2b382d6
  guozhangwang

  committed
  2b382d6

  Copy full SHA for 2b382d6

• KAFKA-2379: Add basic documentation for Kafka Connect.

  Show description for 2b97b6c
  

  ewencp

  authored and

  gwenshap

  committed
  2b97b6c

  Copy full SHA for 2b97b6c

• KAFKA-2769; Multi-consumer integration tests for consumer assignment incl. session timeouts and corresponding fixes

  Show description for 98b6257
  

  apovzner

  authored and

  guozhangwang

  committed
  98b6257

  Copy full SHA for 98b6257

• KAFKA-2274: verifiable consumer and integration testing

  Show description for e46959b
  

  hachikuji

  authored and

  junrao

  committed
  e46959b

  Copy full SHA for e46959b

• KAFKA-2786: Only respond to SinkTask onPartitionsRevoked after the WorkerSinkTask has finished starting up.

  Show description for a621677
  

  ewencp

  authored and

  gwenshap

  committed
  a621677

  Copy full SHA for a621677

• KAFKA-2797: Only run rat when in the .git repository since it require s the .gitignore to generate the list of files to ignore

  Show description for 528d555
  

  ewencp

  authored and

  gwenshap

  committed
  528d555

  Copy full SHA for 528d555

• KAFKA-2792: Don't wait for a response to the leave group message when closing the new consumer.

  Show description for 69f2ad8
  

  ewencp

  authored and

  gwenshap

  committed
  69f2ad8

  Copy full SHA for 69f2ad8

• KAFKA-2798: Use prefixedd configurations for Kafka Connect producer and consumer settings so they do not conflict with the distributed herder's settings.

  Show description for dd8a870
  

  ewencp

  authored and

  gwenshap

  committed
  dd8a870

  Copy full SHA for dd8a870

• MINOR: update system test readme

  Show description for c411ec8
  

  Geoff Anderson

  authored and

  guozhangwang

  committed
  c411ec8

  Copy full SHA for c411ec8

• KAFKA-2795: fix potential NPE in GroupMetadataManager.addGroup

  Show description for 7508ec2
  

  hachikuji

  authored and

  guozhangwang

  committed
  7508ec2

  Copy full SHA for 7508ec2

• KAFKA-2788; Allow specifying principals with comman in ACL CLI.

  Show description for 501ac02
  

  Parth-Brahmbhatt

  authored and

  junrao

  committed
  501ac02

  Copy full SHA for 501ac02

• KAFKA-2793: Use ByteArrayDeserializer instead of StringDeserializer for keys in ConsoleConsumer with new consumer.

  Show description for 75db96e
  

  ewencp

  authored and

  gwenshap

  committed
  75db96e

  Copy full SHA for 75db96e

Commits on Nov 11, 2015

• KAFKA-2801; Process any remaining data in SSL network read buffer after handshake

  Show description for 57ada44
  

  rajinisivaram

  authored and

  junrao

  committed
  57ada44

  Copy full SHA for 57ada44

• KAFKA-2770: Catch and ignore WakeupException for commit upon closing

  Show description for 0ea17e9
  guozhangwang

  committed
  0ea17e9

  Copy full SHA for 0ea17e9

• KAFKA-2790: doc improvements

  Show description for 1828b8e
  gwenshap

  committed
  1828b8e

  Copy full SHA for 1828b8e

Commits on Nov 12, 2015

• KAFKA2805; RecordAccumulator request timeout not enforced when all brokers are gone

  Show description for 39ea9d3
  

  Mayuresh Gharat

  authored and

  junrao

  committed
  39ea9d3

  Copy full SHA for 39ea9d3

• MINOR: Do not collect zk persistent data by default

  Show description for 555fab9
  

  Geoff Anderson

  authored and

  junrao

  committed
  555fab9

  Copy full SHA for 555fab9

• KAFKA-2813; selector doesn't close socket connection on non-IOExceptions

  Show description for 8c37009
  junrao

  committed
  8c37009

  Copy full SHA for 8c37009

• MINOR: Remove InvalidReceiveException catch in SocketServer

  Show description for 33809f5
  

  ijuma

  authored and

  junrao

  committed
  33809f5

  Copy full SHA for 33809f5

• MINOR: Fix logging message in NetworkClient.poll not to mention producer

  Show description for c7b9ccb
  

  ijuma

  authored and

  junrao

  committed
  c7b9ccb

  Copy full SHA for c7b9ccb

• MINOR: Use Kafka artifact compiled with Scala 2.11 in quickstart.html

  Show description for 3ded811
  

  ijuma

  authored and

  junrao

  committed
  3ded811

  Copy full SHA for 3ded811

• TRIVIAL: provide clearer error in describe group when group is inactive

  Show description for 9812493
  

  hachikuji

  authored and

  guozhangwang

  committed
  9812493

  Copy full SHA for 9812493

• KAFKA-2690: Hide passwords while logging the config.

  Show description for c596582
  

  Jakub Nowak

  authored and

  gwenshap

  committed
  c596582

  Copy full SHA for c596582

• MINOR: Increase timeouts for Kafka Connect system test service to make tests more reliable on wimpy nodes.

  Show description for d04a918
  

  ewencp

  authored and

  gwenshap

  committed
  d04a918

  Copy full SHA for d04a918

• KAFKA-2822: DescribeConsumerGroup now returns empty list for non-existent group.

  Show description for 431ffa2
  

  Ashish Singh

  authored and

  guozhangwang

  committed
  431ffa2

  Copy full SHA for 431ffa2

• KAFKA-2814: Make Kafka Connect system test REST requests use hostname that is compatible with running under AWS.

  Show description for c4e069a
  

  ewencp

  authored and

  gwenshap

  committed
  c4e069a

  Copy full SHA for c4e069a

Commits on Nov 13, 2015

• MINOR: Tuned timeout parameter to reduce chance of transient failure

  Show description for e8f92d6
  

  Geoff Anderson

  authored and

  gwenshap

  committed
  e8f92d6

  Copy full SHA for e8f92d6

• KAFKA-2819; catch NoSuchElementException in ConsoleConsumer

  Show description for b06ef94
  

  guozhangwang

  authored and

  junrao

  committed
  b06ef94

  Copy full SHA for b06ef94

• KAFKA-2817; Check if socketChannel is connected in SslTransportLayer.close

  Show description for cb0de17
  

  ijuma

  authored and

  junrao

  committed
  cb0de17

  Copy full SHA for cb0de17

• Minor: Missing License

  Show description for 3e133c4
  

  Sriharsha Chintalapani

  authored and

  gwenshap

  committed
  3e133c4

  Copy full SHA for 3e133c4

• trivial doc changes

  junrao

  committed
  26aae84

  Copy full SHA for 26aae84

• KAFKA-2791; removed deprecated properties

  Show description for 002b6b0
  

  benstopford

  authored and

  junrao

  committed
  002b6b0

  Copy full SHA for 002b6b0

• KAFKA-2821; fix deadlock in group metadata write callback

  Show description for cc51733
  

  hachikuji

  authored and

  junrao

  committed
  cc51733

  Copy full SHA for cc51733

• KAFKA-2768: AdminClient ignore member list for non-stable groups

  Show description for a30a798
  

  Ashish Singh

  authored and

  guozhangwang

  committed
  a30a798

  Copy full SHA for a30a798

• KAFKA-2833; print only group offset / metadata according to the formatter

  Show description for 5b39dca
  

  guozhangwang

  authored and

  junrao

  committed
  5b39dca

  Copy full SHA for 5b39dca

• additional trivial 0.9.0 doc changes

  junrao

  committed
  8857d27

  Copy full SHA for 8857d27

Commits on Nov 14, 2015

• KAFKA-2838; Allow comma in super users, allow comma in CLI authz prop…

  Show description for 3c33858
  

  Parth-Brahmbhatt

  authored and

  junrao

  committed
  3c33858

  Copy full SHA for 3c33858

• trivial 0.9.0 doc changes to AclCommand

  junrao

  committed
  62e2135

  Copy full SHA for 62e2135

• trivial 0.9.0 doc changes to fix links

  junrao

  committed
  e96b723

  Copy full SHA for e96b723

• KAFKA-2624; Change log message position

  Show description for 2261763
  

  Francois Visconte

  authored and

  junrao

  committed
  2261763

  Copy full SHA for 2261763

Commits on Nov 16, 2015

• KAFKA-2831; Do not use ZKUtils in ConsumerGroupCommand if new-consumer is used

  Show description for 6483ae6
  

  ijuma

  authored and

  junrao

  committed
  6483ae6

  Copy full SHA for 6483ae6

• KAFKA-2809; Improve documentation linking

  Show description for 99d9ddc
  

  granthenke

  authored and

  junrao

  committed
  99d9ddc

  Copy full SHA for 99d9ddc

• KAFKA-2721; Avoid handling duplicate LeaderAndISR requests

  Show description for 21ea9cb
  

  lindong28

  authored and

  junrao

  committed
  21ea9cb

  Copy full SHA for 21ea9cb

Commits on Nov 17, 2015

• trivial doc change for building customized user name

  junrao

  committed
  1a7f37b

  Copy full SHA for 1a7f37b

• KAFKA-2848; Use client SSL/SASL config utilities in Kafka Connect to avoid duplication of configs.

  Show description for cae36f5
  

  ewencp

  authored and

  junrao

  committed
  cae36f5

  Copy full SHA for cae36f5

• KAFKA-2847; Remove principal builder class from client configs

  Show description for 1540730
  

  ijuma

  authored and

  junrao

  committed
  1540730

  Copy full SHA for 1540730

• KAFKA-2746; Add support for using ConsumerGroupCommand on secure install

  Show description for 723c6f2
  

  Ashish Singh

  authored and

  junrao

  committed
  723c6f2

  Copy full SHA for 723c6f2

Commits on Nov 18, 2015

• KAFKA-2852; Updating the Authorizer CLI to use a consistent way to specify a list of values for a config options.

  Show description for fda91fc
  

  Parth-Brahmbhatt

  authored and

  junrao

  committed
  fda91fc

  Copy full SHA for fda91fc

• MINOR: fix shutdownHook in ConsoleConsumer

  Show description for 45d6fb7
  

  guozhangwang

  authored and

  junrao

  committed
  45d6fb7

  Copy full SHA for 45d6fb7

• MINOR: Introduce producer.config property to ConsoleProducer

  Show description for 9f2f9fb
  

  ijuma

  authored and

  junrao

  committed
  9f2f9fb

  Copy full SHA for 9f2f9fb

• KAFKA-2841; safe group metadata cache loading/unloading

  Show description for a2bc950
  

  hachikuji

  authored and

  junrao

  committed
  a2bc950

  Copy full SHA for a2bc950

• trivial fix to 0.9.0 docs

  junrao

  committed
  fe855f9

  Copy full SHA for fe855f9

• KAFKA-2859: Fix deadlock in WorkerSourceTask.

  Show description for 537aeae
  

  ewencp

  authored and

  gwenshap

  committed
  537aeae

  Copy full SHA for 537aeae

Commits on Nov 19, 2015

• MINOR: Documentation improvements

  Show description for 26f7979
  

  ijuma

  authored and

  gwenshap

  committed
  26f7979

  Copy full SHA for 26f7979

Commits on Nov 20, 2015

• KAFKA-2860: better handling of auto commit errors

  Show description for 07e2141
  

  hachikuji

  authored and

  junrao

  committed
  07e2141

  Copy full SHA for 07e2141

• KAFKA-2869; Host used by Authorizer should be IP address not hostname/IP

  Show description for 2b3f6d2
  

  ijuma

  authored and

  junrao

  committed
  2b3f6d2

  Copy full SHA for 2b3f6d2

• KAFKA-2867: Fix missing WorkerSourceTask synchronization and handling of InterruptException.

  Show description for 2f51ab2
  

  ewencp

  authored and

  junrao

  committed
  2f51ab2

  Copy full SHA for 2f51ab2

• KAFKA-2863; Add a close() method to Authorizer

  Show description for 81c89e9
  

  ijuma

  authored and

  junrao

  committed
  81c89e9

  Copy full SHA for 81c89e9

• trivial change to 0.9.0 docs to fix outdated ConsumerMetadataRequest

  junrao

  committed
  cd7455c

  Copy full SHA for cd7455c

• trivial change to 0.9.0 docs to fix incorrect ssl.key.password

  junrao

  committed
  6aeaa1e

  Copy full SHA for 6aeaa1e

• KAFKA-2718: Avoid reusing temporary directories in core unit tests

  Show description for 836dd70
  

  rajinisivaram

  authored and

  Guozhang Wang

  committed
  836dd70

  Copy full SHA for 836dd70

• KAFKA-2812: improve consumer integration tests

  Show description for 1742937
  

  hachikuji

  authored and

  Guozhang Wang

  committed
  1742937

  Copy full SHA for 1742937

Commits on Nov 21, 2015

• trivial change: revert incorrect change to ssl.key.password

  junrao

  committed
  fc7243c

  Copy full SHA for fc7243c

Commits on Nov 24, 2015

• trivial doc fix to add link to Quotas

  junrao

  committed
  10b3e6a

  Copy full SHA for 10b3e6a

Commits on Nov 25, 2015

• KAFKA-2877: handle request timeout in sync group

  Show description for 701ac00
  

  hachikuji

  authored and

  guozhangwang

  committed
  701ac00

  Copy full SHA for 701ac00

• KAFKA-2881: Improve Consumer Configs and API Documentation

  Show description for 89e916d
  

  guozhangwang

  authored and

  gwenshap

  committed
  89e916d

  Copy full SHA for 89e916d

• KAFKA-2799: skip wakeup in the follow-up poll() call.

  Show description for c89b6f6
  guozhangwang

  committed
  c89b6f6

  Copy full SHA for c89b6f6

• KAFKA-2718: Prevent temp directory being reused in parallel test runs

  Show description for d96542f
  

  rajinisivaram

  authored and

  guozhangwang

  committed
  d96542f

  Copy full SHA for d96542f

Commits on Nov 26, 2015

• KAFKA-2878; Guard against OutOfMemory in Kafka broker

  Show description for 33b4d3c
  

  rajinisivaram

  authored and

  junrao

  committed
  33b4d3c

  Copy full SHA for 33b4d3c

• KAFKA-2892 Consumer Docs Use Wrong Method

  Show description for 4f3bdca
  

  eljefe6a

  authored and

  gwenshap

  committed
  4f3bdca

  Copy full SHA for 4f3bdca

Commits on Nov 27, 2015

• KAFKA-2882: Add constructor cache for Snappy and LZ4 Output/Input streams in Compressor.java

  Show description for 7d37086
  

  logarithm

  authored and

  guozhangwang

  committed
  7d37086

  Copy full SHA for 7d37086

• KAFKA-2899: improve logging when unexpected exceptions thrown in reading local log

  Show description for 60c4480
  

  benstopford

  authored and

  guozhangwang

  committed
  60c4480

  Copy full SHA for 60c4480

• MINOR: Avoiding warning about generics in sample code

  Show description for e934a10
  

  nurkiewicz

  authored and

  guozhangwang

  committed
  e934a10

  Copy full SHA for e934a10

Commits on Nov 29, 2015

• KAFKA-2906: Fix Connect javadocs, restrict only to api subproject, and clean up javadoc warnings.

  Show description for cbddb07
  

  ewencp

  authored and

  gwenshap

  committed
  cbddb07

  Copy full SHA for cbddb07

Commits on Nov 30, 2015

• MINOR: fix verifiable consumer assertion

  Show description for 0cd6e94
  

  hachikuji

  authored and

  guozhangwang

  committed
  0cd6e94

  Copy full SHA for 0cd6e94

• MINOR: Fixed new consumer Javadoc typo

  Show description for 94dc1f9
  

  Alex Sherwin

  authored and

  guozhangwang

  committed
  94dc1f9

  Copy full SHA for 94dc1f9

Commits on Dec 1, 2015

• KAFKA-2913: missing partition check when removing groups from cache

  Show description for ca24692
  

  hachikuji

  authored and

  guozhangwang

  committed
  ca24692

  Copy full SHA for ca24692

• MINOR: Update "Java Version" section

  Show description for a412d8a
  

  ijuma

  authored and

  guozhangwang

  committed
  a412d8a

  Copy full SHA for a412d8a

• MINOR: Update LinkedIn JVM tuning settings

  Show description for 59c7f6c
  

  ijuma

  authored and

  guozhangwang

  committed
  59c7f6c

  Copy full SHA for 59c7f6c

• MINOR - fix typo in index corruption warning message

  Show description for bb2bcc7
  

  lindong28

  authored and

  guozhangwang

  committed
  bb2bcc7

  Copy full SHA for bb2bcc7

Commits on Dec 2, 2015

• KAFKA-2880: consumer should handle disconnect/timeout for metadata requests

  Show description for 20e9588
  

  hachikuji

  authored and

  guozhangwang

  committed
  20e9588

  Copy full SHA for 20e9588

• Manually ported changes in 8c3c954 to 0.9.0 (no cherry-pick due to conflicts)

  

  Geoff Anderson

  committed
  ee8a7ce

  Copy full SHA for ee8a7ce

Commits on Dec 3, 2015

• MINOR: ConsoleConsumer - Fix number of processed messages count

  Show description for 2b4c5dc
  

  luafran

  authored and

  guozhangwang

  committed
  2b4c5dc

  Copy full SHA for 2b4c5dc

• KAFKA-2942: inadvertent auto-commit when pre-fetching can cause message loss

  Show description for 7b46a99
  

  hachikuji

  authored and

  guozhangwang

  committed
  7b46a99

  Copy full SHA for 7b46a99

Commits on Dec 5, 2015

• MINOR: backport fix to partition assignor order (KAFKA-2931)

  Show description for 8687c09
  

  hachikuji

  authored and

  gwenshap

  committed
  8687c09

  Copy full SHA for 8687c09

• KAFKA-2950: Fix performance regression in the producer

  Show description for 8b65ec9
  

  jkreps

  authored and

  guozhangwang

  committed
  8b65ec9

  Copy full SHA for 8b65ec9

Commits on Dec 8, 2015

• MINOR: Remove unused DoublyLinkedList

  Show description for 168b759
  

  granthenke

  authored and

  guozhangwang

  committed
  168b759

  Copy full SHA for 168b759

• KAFKA-2957: Fix typos in Kafka documentation

  Show description for 1f98b03
  

  vahidhashemian

  authored and

  gwenshap

  committed
  1f98b03

  Copy full SHA for 1f98b03

Commits on Dec 9, 2015

• KAFKA-2924: support offsets topic in DumpLogSegments

  Show description for 78192b8
  

  hachikuji

  authored and

  guozhangwang

  committed
  78192b8

  Copy full SHA for 78192b8

• KAFKA-2973; Fix leak of child sensors on remove

  Show description for f906706
  

  ijuma

  authored and

  gwenshap

  committed
  f906706

  Copy full SHA for f906706

• KAFKA-2972; Add missing partitionsRemaingList.add in ControlledShutdownResponse constructor

  Show description for 83c1e33
  

  ijuma

  authored and

  guozhangwang

  committed
  83c1e33

  Copy full SHA for 83c1e33

Commits on Dec 10, 2015

• KAFKA-2974; == is used incorrectly in a few places in Java code

  Show description for a5fa661
  

  eribeiro

  authored and

  guozhangwang

  committed
  a5fa661

  Copy full SHA for a5fa661

• KAFKA-2578; Client Metadata internal state should be synchronized

  Show description for 7684f6d
  

  eribeiro

  authored and

  ewencp

  committed
  7684f6d

  Copy full SHA for 7684f6d

• KAFKA-2893: Add a simple non-negative partition seek check

  Show description for 416210e
  

  Jin Xing

  authored and

  guozhangwang

  committed
  416210e

  Copy full SHA for 416210e

• KAFKA-2926; [MirrorMaker] InternalRebalancer calls wrong method of external rebalancer

  Show description for ba09aef
  

  gwenshap

  authored and

  ewencp

  committed
  ba09aef

  Copy full SHA for ba09aef

Commits on Dec 11, 2015

• KAFKA-2981: Fix javadoc in KafkaConsumer

  Show description for 8071f10
  

  vesense

  authored and

  guozhangwang

  committed
  8071f10

  Copy full SHA for 8071f10

Commits on Dec 14, 2015

• KAFKA-2978: consumer stops fetching when consumed and fetch positions get out of sync

  Show description for 974e5aa
  

  hachikuji

  authored and

  guozhangwang

  committed
  974e5aa

  Copy full SHA for 974e5aa

Commits on Dec 15, 2015

• KAFKA-2990; Fix NoSuchMethodError in Pool with cast to ConcurrentMap

  Show description for 20b0969
  

  hachikuji

  authored and

  ewencp

  committed
  20b0969

  Copy full SHA for 20b0969

• MINOR: Documentation updates for reserved.broker.max.id

  Show description for 52a3e7b
  

  edenhill

  authored and

  ewencp

  committed
  52a3e7b

  Copy full SHA for 52a3e7b

Commits on Dec 16, 2015

• MINOR: Add information to upgrade notes

  Show description for 6533933
  

  ijuma

  authored and

  ewencp

  committed
  6533933

  Copy full SHA for 6533933

Commits on Dec 21, 2015

• KAFKA-2058: Fix ProducerTest.testSendWithDeadBroker transient failure

  Show description for d5698fa
  

  Jin Xing

  authored and

  guozhangwang

  committed
  d5698fa

  Copy full SHA for d5698fa

• KAFKA-2977: Transient Failure in kafka.log.LogCleanerIntegrationTest.cleanerTest

  Show description for 9765354
  

  Jin Xing

  authored and

  guozhangwang

  committed
  9765354

  Copy full SHA for 9765354

• KAFKA-2455: Fix failure in kafka.consumer.MetricsTest.testMetricsLeak

  Show description for 4f2d172
  

  Jin Xing

  authored and

  guozhangwang

  committed
  4f2d172

  Copy full SHA for 4f2d172

• KAFKA-3014: fix integer overflow problem in leastLoadedNode

  Show description for 40acb99
  

  hachikuji

  authored and

  guozhangwang

  committed
  40acb99

  Copy full SHA for 40acb99

Commits on Dec 22, 2015

• MINOR: Fix typo in documentation

  Show description for 00ba8e0
  

  vahidhashemian

  authored and

  guozhangwang

  committed
  00ba8e0

  Copy full SHA for 00ba8e0

Commits on Dec 24, 2015

• KAFKA-3002; Allow uppercase letters in hostnames

  Show description for 767de4b
  

  sasakitoa

  authored and

  ewencp

  committed
  767de4b

  Copy full SHA for 767de4b

Commits on Dec 30, 2015

• Change version in gradle.properties

  

  MinJi Kim

  authored and

  Narendra Agrawal

  committed
  26b295d

  Copy full SHA for 26b295d

• MAPR: Initial changes for hooking up marlin

  

  MinJi Kim

  authored and

  Narendra Agrawal

  committed
  fb51d30

  Copy full SHA for fb51d30

• MAPR: modified ConsumerConfig to accept empty string as default for bootstrap.servers

  

  MinJi Kim

  authored and

  Narendra Agrawal

  committed
  62721c7

  Copy full SHA for 62721c7

• MAPR: minor bug fix in commitAsync

  

  MinJi Kim

  authored and

  Narendra Agrawal

  committed
  d615456

  Copy full SHA for d615456

• MAPR: add default stream config param, add new KafkaConsumer.listTopics(String) api

  

  MinJi Kim

  authored and

  Narendra Agrawal

  committed
  19b978a

  Copy full SHA for 19b978a

• MAPR: merge conflicts with 0.9.0

  

  MinJi Kim

  authored and

  Narendra Agrawal

  committed
  843d273

  Copy full SHA for 843d273

• MAPR: add new KafkaConsumer.listTopics(Pattern) api

  

  MinJi Kim

  authored and

  Narendra Agrawal

  committed
  48b924a

  Copy full SHA for 48b924a

• MAPR: add new KafkaConsumer.listTopic(Pattern) api, fix minor typo

  

  MinJi Kim

  authored and

  Narendra Agrawal

  committed
  eddc75f

  Copy full SHA for eddc75f

• MAPR: adding default values to default stream

  

  MinJi Kim

  authored and

  Narendra Agrawal

  committed
  a7437ff

  Copy full SHA for a7437ff

• MAPR-21536: rename marlin to streams in mapr specific config parameters.

  

  Narendra Agrawal

  committed
  3ccab91

  Copy full SHA for 3ccab91

• MAPR-21535: Update the maven artifact name to streams

  

  Smidth Panchamia

  authored and

  Narendra Agrawal

  committed
  15eef18

  Copy full SHA for 15eef18

• MAPR-21517 - need additional control over generated POM for kafka-clients

  

  Patrick Wong

  authored and

  Narendra Agrawal

  committed
  30db768

  Copy full SHA for 30db768

• MAPR-21736 - Change the package name of the MarlinProducer and MarlinListener class as per changes in mercurial

  

  Narendra Agrawal

  committed
  7507a03

  Copy full SHA for 7507a03

• MAPR-20370: add producer and timestamp to messages

  Show description for 0f6594b
  

  Pindikura Ravindra

  committed
  0f6594b

  Copy full SHA for 0f6594b

Commits on Jan 4, 2016

• MAPR-22006 - publish kakfa-log4j-appender and kafka-tools

  pwong-mapr

  committed
  4080a40

  Copy full SHA for 4080a40

• MAPR-22006 - fix

  pwong-mapr

  committed
  405c327

  Copy full SHA for 405c327

Commits on Jan 5, 2016

• Bug 22005 : Make Mirror-maker work across MapR streams

  Show description for d4fba3a
  

  Pindikura Ravindra

  committed
  d4fba3a

  Copy full SHA for d4fba3a

Commits on Jan 20, 2016

• BUG 22237 : make rpc timeout params of streams consistent with fileclient

  Show description for c4b524e
  

  Pindikura Ravindra

  committed
  c4b524e

  Copy full SHA for c4b524e

Commits on Jan 25, 2016

• Bug 22287: Reduce the log level for uninitialized consumer / producer logs to info

  mansiash

  committed
  2b9b1da

  Copy full SHA for 2b9b1da

Commits on Jan 26, 2016

• Changed the run.sh script to pick up mapr classpaths.

  mansiash

  committed
  c401227

  Copy full SHA for c401227

Commits on Jan 29, 2016

• MAPR-22352 added config streams.consumer.buffer.memory

  

  Narendra Agrawal

  committed
  a26b9d2

  Copy full SHA for a26b9d2

Commits on Feb 2, 2016

• Bug 22413 : kafka-consumer-perf-test.sh with 80 partitions times out

  Show description for 165df5d
  

  Pindikura Ravindra

  committed
  165df5d

  Copy full SHA for 165df5d

• MAPR-22414 - improved handling of the case where MapR Streams dependency should not be added to Maven-style artifact

  

  Patrick Wong

  authored and

  Patrick Wong

  committed
  5d500b2

  Copy full SHA for 5d500b2

• single-character typo

  

  Patrick Wong

  authored and

  Patrick Wong

  committed
  69bcd03

  Copy full SHA for 69bcd03

• fix for cases when maprVersion is defined as "0-SNAPSHOT" or similar

  

  Patrick Wong

  authored and

  Patrick Wong

  committed
  eeef4d6

  Copy full SHA for eeef4d6

Commits on Feb 19, 2016

• prepare for release 0.9.0.0-mapr-1602

  pwong-mapr

  committed
  fd22737

  Copy full SHA for fd22737

Commits on Jul 15, 2016

• gradle

  

  Matt Anderson

  committed
  f614021

  Copy full SHA for f614021

• pull upstream

  

  Matt Anderson

  committed
  71d53a2

  Copy full SHA for 71d53a2

• resolved merge conflicts and begin mapr impls

  

  Matt Anderson

  committed
  77aa121

  Copy full SHA for 77aa121

• resolved conflicts

  

  Matt Anderson

  committed
  3e6c9ec

  Copy full SHA for 3e6c9ec

Commits on Jul 18, 2016

• consumer/producer client updates for mapr

  

  Matt Anderson

  committed
  575905d

  Copy full SHA for 575905d

• fixed consumer/producer oss kafka tests

  

  Matt Anderson

  committed
  45bea95

  Copy full SHA for 45bea95

Commits on Jul 21, 2016

• updated tests

  

  Matt Anderson

  committed
  962a710

  Copy full SHA for 962a710

• update to dependencies

  

  Matt Anderson

  committed
  f59085a

  Copy full SHA for f59085a