Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Mar 27, 2020

• Number of placeholder doesn't match number of arguments in logging (apache#6618)

  yjshen

  authored
  988e03e

Commits on Mar 11, 2020

• [Maven Cleanup] Remove managed-ledger and zk-utils test-jar dependencies when possible (apache#6513)

  Show description for efe19e0
  yjshen

  authored
  efe19e0

Commits on Mar 6, 2020

• Independent schema is set for each consumer generated by topic (apache#6356)

  Show description for 8003d08
  congbobo184

  authored
  8003d08

Commits on Feb 21, 2020

• [Pulsar-Client] Stop shade snappy-java in pulsar-client-shaded (apache#6375)

  Show description for 3197dcd
  yjshen

  authored
  3197dcd

Commits on Feb 10, 2020

• [pulsar-kafka] support block-producer on queue-full with sendTimeOut configuration (apache#6139)

  Show description for 5fe096d
  rdhabalia

  authored
  5fe096d

Commits on Jan 14, 2020

• [build] Skip javadoc task for pulsar-client-kafka-compact modules (apache#5836)

  Show description for 97f9431
  sijie

  authored
  97f9431

Commits on Dec 20, 2019

• Added catch for NoClassDefFoundError wherever there was a ClassNotFoundException (apache#5870)

  Show description for 17e22d1
  

  phreed

  authored and

  sijie

  committed
  17e22d1

Commits on Dec 9, 2019

• Bump version to 2.6.0 (apache#5820)

  Show description for 702790a
  sijie

  authored
  702790a

Commits on Nov 6, 2019

• Use StandardCharsets.UTF_8 for converting String to bytes (apache#5372)

  Show description for 0053dbc
  

  liketic

  authored and

  sijie

  committed
  0053dbc

Commits on Nov 5, 2019

• expose new message with different schema (apache#5517)

  Show description for 669b916
  

  yittg

  authored and

  sijie

  committed
  669b916

Commits on Oct 31, 2019

• [Test] Migrate deprecated Matchers to ArgumentMatchers (apache#5423)

  Show description for 3d5bc0a
  

  liketic

  authored and

  merlimat

  committed
  3d5bc0a

Commits on Sep 26, 2019

• Removed managed-ledger-shaded artifact (apache#4200)

  Show description for 806eab5
  merlimat

  authored
  806eab5

Commits on Sep 6, 2019

• Make client keepalive interval configurable on pulsar-client-kafka (apache#5131)

  

  masnnuller

  authored and

  merlimat

  committed
  0f40adc

Commits on Aug 6, 2019

• Add support of pulsar-kafka-adapter for kafka-0.8 api (apache#4797)

  Show description for 7b185db
  rdhabalia

  authored
  7b185db

• Add support of pulsar-kafka-adapter for kafka-0.9 api (apache#4886)

  Show description for f6ed037
  

  fxbing

  authored and

  sijie

  committed
  f6ed037

Commits on Jul 24, 2019

• Fix：PulsarKafkaProducer is not thread safe (apache#4745)

  Show description for 0362944
  

  fxbing

  authored and

  sijie

  committed
  0362944

Commits on Jul 10, 2019

• Upgrade to Mockito 2.x (apache#4671)

  Show description for 108780c
  

  merlimat

  authored and

  jiazhai

  committed
  108780c

Commits on Jul 7, 2019

• Support Pulsar schema for pulsar kafka client wrapper (apache#4534)

  Show description for 99d3c11
  

  tuteng

  authored and

  sijie

  committed
  99d3c11

Commits on Jul 2, 2019

• Issue apache#4638 : Update Kafka connect-api to version 2.3.0 (apache#4650)

  Show description for deb6492
  

  willome

  authored and

  merlimat

  committed
  deb6492

Commits on Jun 25, 2019

• Bumped version to 2.5.0-SNAPSHOT (apache#4581)

  

  codelipenghui

  authored and

  sijie

  committed
  5fa6c36

Commits on Jun 18, 2019

• [pulsar-kafka] Fix KafkaProducerInterceptorWrapper handles LongSerializer (apache#4549)

  Show description for 4c352f0
  sijie

  authored
  4c352f0

Commits on May 29, 2019

• Configure static PulsarByteBufAllocator to handle OOM errors (apache#4196)

  Show description for 3b33c66
  merlimat

  authored
  3b33c66

Commits on Mar 28, 2019

• Support Kafka's ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG in PulsarKafkaConsumer. (apache#3911)

  Show description for 0487804
  

  MarvinCai

  authored and

  merlimat

  committed
  0487804

Commits on Mar 26, 2019

• Support Kafka's ConsumerConfig.MAX_POLL_RECORDS_CONFIG to config max number of message will return in a single poll. (apache#3887)

  Show description for b42c1e5
  

  MarvinCai

  authored and

  merlimat

  committed
  b42c1e5

Commits on Mar 20, 2019

• Add a wrapper around Kafka's ProducerInterceptor to support Kafka's ProducerConfig.INTERCEPTOR_CLASSES_CONFIG. apache#1090 (apache#3843)

  Show description for e77a165
  

  MarvinCai

  authored and

  sijie

  committed
  e77a165

Commits on Mar 19, 2019

• Fix the loop of consumer poll, so the consumer can cache more than one record in signal poll. (apache#3852)

  

  se7enkings

  authored and

  merlimat

  committed
  f1be6bd

Commits on Mar 11, 2019

• Support Kafka's ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG. (apache#3797)

  Show description for 117321d
  

  MarvinCai

  authored and

  sijie

  committed
  117321d

Commits on Mar 9, 2019

• Add support for Kafka's ProducerConfig.CONNECTIONS_MAX_IDLE_MS_CONFIG (apache#1090) (apache#3753)

  Show description for 18e3ab1
  

  MarvinCai

  authored and

  sijie

  committed
  18e3ab1

Commits on Feb 15, 2019

• Bumped version to 2.4.0-SNAPSHOT (apache#3604)

  merlimat

  authored
  53ba1a4

Commits on Feb 11, 2019

• In PulsarKafkaProducer use flush() from pulsar API (apache#3549)

  merlimat

  authored
  894146a

Commits on Feb 8, 2019

• Added suppport for Kafka partitioner and explicit setting of partition on record (apache#3462)

  Show description for c448aaa
  merlimat

  authored
  c448aaa

Commits on Jan 25, 2019

• Use topics in public/default namespaces for kafka ProducerExample and ConsumerExample (apache#3401)

  Show description for 3255957
  

  ambition119

  authored and

  sijie

  committed
  3255957

Commits on Jan 24, 2019

• Use ConsumerConfig instead of ProducerConfig in PulsarKafkaConsumer (apache#3394)

  

  murong00

  authored and

  merlimat

  committed
  fdbdb96

Commits on Jan 21, 2019

• Support to set subscriptionTopicsMode via properties. (apache#3395)

  

  murong00

  authored and

  merlimat

  committed
  b9370c3

Commits on Jan 5, 2019

• Adding config auto.offset.reset to PulsarKafkaConsumer (apache#3273)

  Show description for ef82f04
  

  ConcurrencyPractitioner

  authored and

  merlimat

  committed
  ef82f04

Pagination

PreviousNext