Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/602
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/648
KAFKA-2837: fix transient failure of kafka.api.ProducerBounceTest >
testBrokerFailure
I can reproduced this transient failure, it seldom happen;
code is like below:
// rolling bou
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/648
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/648
KAFKA-2837: fix transient failure of kafka.api.ProducerBounceTest >
testBrokerFailure
I can reproduced this transient failure, it seldom happen;
code is like below:
// rolling bou
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/648
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/648
KAFKA-2837: fix transient failure of kafka.api.ProducerBounceTest >
testBrokerFailure
I can reproduced this transient failure, it seldom happen;
code is like below:
// rolling bou
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/595
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/669
KAFKA-2875:
Hi @ijuma
I repopened this PR;
I make slf4jlog4j12 dependency version to be 1.7.13, by this way, the 1.7.6
transitive dependency version will be overriten I think;
From my
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/648
KAFKA-2837: fix transient failure of kafka.api.ProducerBounceTest >
testBrokerFailure
I can reproduced this transient failure, it seldom happen;
code is like below:
// rolling bou
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/648
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/671
KAFKA-2977: Transient Failure in
kafka.log.LogCleanerIntegrationTest.cleanerTest
Hi @guozhangwang
-
Code is as below:
val appends = writeDups(numKeys = 100
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/689
KAFKA-2058: ProducerTest.testSendWithDeadBroker transient failure
I reproduced this transient failure;
It turns that waitUntilMetadataIsPropagated is not enough;
in "onBrokerSt
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/669
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/693
KAFKA-2875: remove slf4j multi binding warnings when running form source
distribution
hi @ijuma I reopened this pr again (sorry for my inexperience using github);
I think I did much
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/694
KAFKA-2455: Test Failure: kafka.consumer.MetricsTest > testMetricsLeak
@guozhangwang
I reproduced this;
Every time this test failed, I found extra "type=DelayedFetchMetric
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/671
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/671
KAFKA-2977: Transient Failure in
kafka.log.LogCleanerIntegrationTest.cleanerTest
Hi @guozhangwang
Code is as below:
val appends = writeDups(numKeys = 100, numDups = 3, log
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/671
KAFKA-2977: Transient Failure in
kafka.log.LogCleanerIntegrationTest.cleanerTest
Code is as below:
val appends = writeDups(numKeys = 100, numDups = 3, log
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/671
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/723
KAFKA-2944: fix NullPointerException in KafkaConfigStorage
Lost of "config messages" can affect the logic of KafkaConfigStorage;
Call readToEnd after sending each message to KafkaB
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/723
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/723
KAFKA-2944: fix NullPointerException in KafkaConfigStorage
Lost of "config messages" can affect the logic of KafkaConfigStorage;
Call readToEnd after sending each message to KafkaB
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/723
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/723
KAFKA-2944: fix NullPointerException in KafkaConfigStorage
Lost of "config messages" can affect the logic of KafkaConfigStorage;
Call readToEnd after sending each message to KafkaB
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/723
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/723
KAFKA-2944: fix NullPointerException in KafkaConfigStorage
Lost of "config messages" can affect the logic of KafkaConfigStorage;
Call readToEnd after sending each message to KafkaB
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/723
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/723
KAFKA-2944: fix NullPointerException in KafkaConfigStorage
Lost of "config messages" can affect the logic of KafkaConfigStorage;
Call readToEnd after sending each message to KafkaB
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/723
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/723
KAFKA-2944: fix NullPointerException in KafkaConfigStorage
Lost of "config messages" can affect the logic of KafkaConfigStorage;
Call readToEnd after sending each message to KafkaB
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/734
KAFKA-2934: Offset storage file configuration in Connect standalone mode is
not included in StandaloneConfig
Added offsetBackingStore config to StandaloneConfig and DistributedConfig;
Added
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/734
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/734
KAFKA-2934: Offset storage file configuration in Connect standalone mode is
not included in StandaloneConfig
Added offsetBackingStore config to StandaloneConfig and DistributedConfig;
Added
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/693
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/693
KAFKA-2875: remove slf4j multi binding warnings when running form source
distribution
hi @ijuma I reopened this pr again (sorry for my inexperience using github);
I think I did much
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/782
Trunk kafka 3054
The exceptions may propagate to DistributedHerder when start or stop
connectors or tasks;
The best solution is to track the track the status of connectors and tasks;
This
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/782
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/782
KAFKA-3054: Connect Herder fail if sent a wrong connector config or task
config, catch exceptions to guard
The exceptions may propagate to DistributedHerder when start or stop
connectors or
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/783
KAFKA-3106: Fix updating an existing connector config from REST API, GET a
connector config will fail
When query for connector and task config info by REST API, method of
"checkConfigSynced&
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/723
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/723
KAFKA-2944: fix NullPointerException in KafkaConfigStorage
Lost of "config messages" can affect the logic of KafkaConfigStorage;
Call readToEnd after sending each message to KafkaB
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/723
KAFKA-2944: fix NullPointerException in KafkaConfigStorage
Lost of "config messages" can affect the logic of KafkaConfigStorage;
Call readToEnd after sending each message to KafkaB
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/723
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/782
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/782
KAFKA-3054: Connect Herder fail if sent a wrong connector config or task
config, catch exceptions to guard
The exceptions may propagate to DistributedHerder when start or stop
connectors or
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/693
KAFKA-2875: remove slf4j multi binding warnings when running form source
distribution
hi @ijuma I reopened this pr again (sorry for my inexperience using github);
I think I did much
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/693
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/693
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/693
KAFKA-2875: remove slf4j multi binding warnings when running form source
distribution
hi @ijuma I reopened this pr again (sorry for my inexperience using github);
I think I did much
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/693
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/693
KAFKA-2875: remove slf4j multi binding warnings when running form source
distribution
hi @ijuma I reopened this pr again (sorry for my inexperience using github);
I think I did much
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/693
KAFKA-2875: remove slf4j multi binding warnings when running form source
distribution
hi @ijuma I reopened this pr again (sorry for my inexperience using github);
I think I did much
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/693
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/693
KAFKA-2875: remove slf4j multi binding warnings when running form source
distribution
hi @ijuma I reopened this pr again (sorry for my inexperience using github);
I think I did much
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/693
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/693
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/693
KAFKA-2875: remove slf4j multi binding warnings when running form source
distribution
hi @ijuma I reopened this pr again (sorry for my inexperience using github);
I think I did much
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/734
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/734
KAFKA-2934: Offset storage file configuration in Connect standalone mode is
not included in StandaloneConfig
Added offsetBackingStore config to StandaloneConfig and DistributedConfig;
Added
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/734
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/734
KAFKA-2934: Offset storage file configuration in Connect standalone mode is
not included in StandaloneConfig
Added offsetBackingStore config to StandaloneConfig and DistributedConfig;
Added
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/225
MOD: for test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ZoneMayor/kafka trunk
Alternatively you can review and apply these changes as
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/225
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/226
MOD: test again
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ZoneMayor/kafka trunk
Alternatively you can review and apply these changes as
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/226
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/227
okok-test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ZoneMayor/kafka trunk
Alternatively you can review and apply these changes as the
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/227
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/228
more test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ZoneMayor/kafka trunk
Alternatively you can review and apply these changes as the
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/228
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor reopened a pull request:
https://github.com/apache/kafka/pull/228
more test
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ZoneMayor/kafka trunk
Alternatively you can review and apply these changes as the
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/228
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/531
KAFKA-2605: Replace 'catch: Throwable' clauses with 'NonFatal'
'catch: Throwable' will catch VirtualMachineError, ThreadDeath,
InterruptedException,
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/531
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/532
KAFKA-2605: Replace 'catch: Throwable' clauses with 'NonFatal'
'catch: Throwable' will catch VirtualMachineError, ThreadDeath,
InterruptedException,
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/532
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/558
KAFKA-2361: unit test failure in ProducerFailureHandlingTest.testNotEâ¦
the same issue stated at https://issues.apache.org/jira/browse/KAFKA-1999,
but on branch 0.8.2, still not fixed @junrao
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/558
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/571
KAFKA-2361: unit test failure in ProducerFailureHandlingTest.testNotEâ¦
same issue with KAFKA-1999, so I want to fix it
https://issues.apache.org/jira/browse/KAFKA-1999
You can merge this
Github user ZoneMayor closed the pull request at:
https://github.com/apache/kafka/pull/571
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/595
KAFKA-2875: remove slf4j multi binding warnings when running form source
distribution
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/602
Trunk kafka 2839
I believe there is a bug in KafkaBasedLogTest implementation;
Records are appended to "KafkaBasedLog" by :
consumer.addRecord(new ConsumerRecord<>(TOPI
GitHub user ZoneMayor opened a pull request:
https://github.com/apache/kafka/pull/628
KAFKA-2893: Add a simple non-negative partition seek check
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ZoneMayor/kafka trunk-KAFKA-2893
82 matches
Mail list logo
