8000 Commits · raviperi/kafka · GitHub

Repository navigation

Commits

Commits on Jul 14, 2016
- Introduces new configuration to specify if underlying OS or environment supports updates to memory mapped files
  raviperi
  committed
  779b5d0
Commits on Jul 12, 2016
- KAFKA-2945; CreateTopic - protocol and server side implementation
  
  granthenke
  authored and
  junrao
  committed
  fc47b9f
Commits on Jul 11, 2016
- KAFKA-3887 Follow-up: add unit test for null checking in KTable aggregates
  guozhangwang
  committed
  136a8fa
- KAFKA-3562; Handle topic deletion during a send
  
  rajinisivaram
  authored and
  ijuma
  committed
  c439268
- KAFKA-3942; Change IntegrationTestUtils.purgeLocalStreamsState to use java.io.tmpdir
  
  dguy
  authored and
  ijuma
  committed
  383cec9
- KAFKA-3725; Update documentation with regards to XFS
  
  Todd Palino
  authored and
  ijuma
  committed
  e0eaa7f
- KAFKA-2941: Clarify docs for key and value Converters
  
  ewencp
  authored and
  gwenshap
  committed
  f8a7ace
Commits on Jul 9, 2016
- KAFKA-3849; Add explanation on why polling every second in MirrorMaker is required
  
  Ashish Singh
  authored and
  ijuma
  committed
  2dfbf4b
- MINOR: Typo fix in comments
  
  naferx
  authored and
  ijuma
  committed
  a5da2a4
- MINOR: Update design.html
  
  nihed
  authored and
  ijuma
  committed
  c2459d3
- KAFKA-3844; Sort configuration items in log
  
  rekhajoshm
  authored and
  ijuma
  committed
  4b5ed36
Commits on Jul 8, 2016
- KAFKA-3111; Fix ConsumerPerformance reporting to use time-based instead of message-based intervals
  
  vahidhashemian
  authored and
  junrao
  committed
  0edaa89
- KAFKA-3920: Add Schema source connector to Kafka Connect
  
  Ishiihara
  authored and
  ewencp
  committed
  542350d
- KAFKA-3887: KAFKA-3817 follow-up to avoid forwarding value if it is null in KTableRepartition
  guozhangwang
  committed
  730bf9a
Commits on Jul 6, 2016
- KAFKA-3926: Fix transient test failure in RegexSourceIntegrationTest
  
  bbejeck
  authored and
  guozhangwang
  committed
  efc4c88
- KAFKA-3836: KStreamReduce and KTableReduce should not pass nulls to Deserializers
  
  jeyhunkarimov
  authored and
  guozhangwang
  committed
  7218648
- KAFKA-3794: added stream / table names as prefix to print / writeAsText
  
  bbejeck
  authored and
  guozhangwang
  committed
  b64302f
- KAFKA-3802; log mtimes reset on broker restart / shutdown
  
  Moritz Siuts
  authored and
  ijuma
  committed
  15e0087
Commits on Jul 5, 2016
- MINOR: fix generics in Windows.segments and Windows.until
  
  dguy
  authored and
  guozhangwang
  committed
  dca263b
- MINOR: Fix generics in KStream.groupBy(...)
  
  dguy
  authored and
  guozhangwang
  committed
  416c3a7
- HOTFIX: Auto-repartitioning for merge() and code simplifications
  
  mjsax
  authored and
  guozhangwang
  committed
  12fa188
- MINOR: Fix few documentation errors in streams quickstart
  
  Alex Glikson
  authored and
  guozhangwang
  committed
  87b3ce1
Commits on Jul 4, 2016
- KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern) subscriptions
  
  vahidhashemian
  authored and
  ewencp
  committed
  d7de59a
Commits on Jul 2, 2016
- MINOR: Warning instead of error if TGT cannot be renewed beyond the next expiry date
  
  Sriharsha Chintalapani
  authored and
  ijuma
  committed
  31b4460
- MINOR: Typo fix in docs ops
  
  thanasis00
  authored and
  ijuma
  committed
  0f8b679
- MINOR: Fix consumer constructor doc string
  
  granthenke
  authored and
  ijuma
  committed
  f1323d4
- MINOR: remove "auto.commit.interval.ms" from "Manual Offset Control" example
  
  xuwei-k
  authored and
  ijuma
  committed
  32e24b7
Commits on Jul 1, 2016
- KAFKA-3902: Optimize KTable.filter in Streams DSL to avoid forwarding if both old and new values are null
  
  phderome
  authored and
  guozhangwang
  committed
  2098529
- MINOR: fix Bash shebang on vagrant/ scripts
  
  shikhar
  authored and
  ewencp
  committed
  5a97304
- MINOR: bug fixes to ducktape services
  
  alexlod
  authored and
  ewencp
  committed
  7edaa3d
Commits on Jun 30, 2016
- KAFKA-3846: KIP-65: include timestamp in Connect record types
  
  shikhar
  authored and
  ewencp
  committed
  44ad7b5
- MINOR: Fix ambiguous log message in RecordCollector
  
  kawamuray
  authored and
  guozhangwang
  committed
  3605ffa
- KAFKA-3740: Part I: expose StreamConfig properties in ProcessorContext
  
  Henry Cai
  authored and
  guozhangwang
  committed
  7d6b416
- HOTFIX: Check JoinWindow boundaries
  
  mjsax
  authored and
  guozhangwang
  committed
  7e9f5a7
Commits on Jun 29, 2016
- KAFKA-3890: Streams use same task assignment on cluster rolling restart
  
  Henry Cai
  authored and
  guozhangwang
  committed
  a34f78d

0