date:20210118

Re: [DISCUSS] KIP-705: Selectively Disable Topology Optimizations

2021-01-18 Thread Guozhang Wang

Thanks for the KIP Almog!

I am in favor of the motivation of this proposal, and just throwing out an
alternative about the API here: what do you think if we reuse the
`TOPOLOGY_OPTIMIZATION` config but allow it it accept a list of strings
instead of a single string, in the following semantics:

* "none": disable all optimization rules.
* "all", "-rule1", "-rule2": enable all optimization except rule1 and rule2.
* "rule1",  "rule2": enable only rule1 and rule2 (i.e. enumerate).
* "none", "rule1", "rule2": not accepted, throw error.



Of course, for this KIP's scope itself, we can just do it for one specific
rule of "source-changelog". I'm just wondering about the general framework
for extending the current configuration here.

Guozhang


On Wed, Jan 13, 2021 at 10:42 AM Almog Gavra  wrote:

> Hello,
>
> I would like to start the discussion thread for KIP-705:
>
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-705%3A+Selectively+Disable+Topology+Optimizations
>
> The KIP is proposing an additional streams configuration that allows to
> selectively disable optimizations under the topology.optimization bucket.
> Specifically, the first optimization that can be disabled is the
> source-topic-as-changelog optimization.
>
> Cheers,
> Almog
>


-- 
-- Guozhang

Re: [VOTE] KIP-659: Improve TimeWindowedDeserializer and TimeWindowedSerde to handle window size

2021-01-18 Thread Guozhang Wang

Read the above updates and the KIP's scope. Makes sense to me. +1 still
counts :)

On Wed, Jan 13, 2021 at 2:04 PM Sophie Blee-Goldman 
wrote:

> That sounds good to me. Thanks for reviving this
>
> Sophie
>
> On Wed, Jan 13, 2021 at 7:47 AM Leah Thomas  wrote:
>
> > Hey all,
> >
> > Bringing this back up for discussion.
> >
> > It seems like the next steps are to:
> > 1. rename the config "window.size.ms"
> > 2. ensure that users set window size EITHER through the config OR through
> > the constructor. On this note, it may make sense to remove the default
> for
> > the `window.size.ms` config, so that there won't be a fall back if the
> > window size isn't set in either spot. WDYT? This could also address the
> > issue of multiple window sizes within a streams app.
> >
> > I see what Sophie is saying about the `default.windowed.key.serde.inner`
> > config, but I do think deprecating and moving those configs would
> require a
> > larger discussion. I'm open to looping them into this KIP if we feel like
> > it's vital (or incredibly convenient with low cost to users), but my
> > initial reaction is to leave that out for now and work within the current
> > set-up for window size.
> >
> > Thanks for all the comments so far,
> > Leah
> >
> > On Tue, Sep 29, 2020 at 10:44 PM Sophie Blee-Goldman <
> sop...@confluent.io>
> > wrote:
> >
> > > There are two cases where you need to specify the window size --
> directly
> > > using a
> > > Consumer (eg the console consumer) or reading as an input topic within
> > > Streams.
> > > We need a config for the first case, since you can't pass a
> Deserializer
> > > object to the
> > > console consumer. In the Streams case, the reverse is true, and you
> have
> > to
> > > pass in
> > > an actual Serde object.
> > >
> > > Imo we should keep these two cases separate and not use the config for
> > the
> > > Streams
> > > case at all. But that's hard to enforce (we'd have to strip the config
> > out
> > > of the user's
> > > StreamsConfig if they tried to use it within Streams, for example) and
> it
> > > also puts us
> > > in an awkward position due to the  default.windowed.inner.serde.class
> > > configs. If
> > > they can specify the inner serde class through their Streams app
> config,
> > > they
> > > should be able to specify the window size through config as well.
> > Otherwise
> > > we
> > > either force a mix-and-match as Matthias described, or you just always
> > have
> > > to
> > > specify both the inner class and the window size in the constructor, at
> > > which
> > > point, why even have the default.windowed.inner.serde.class config at
> > all?
> > >
> > > ...
> > > that's not a rhetorical question, actually. Personally I do think we
> > should
> > > deprecate the default.windowed.serde.inner.class and replace it with
> > > separate
> > > windowed.serializer.inner.class/windowed.deserializer.inner.class
> > configs.
> > > This
> > > way it's immediately obvious that the configs are only for the
> > > Consumer/Producer,
> > > and you should construct your own TimeWindowedSerde with all the
> > necessary
> > > parameters for use in your Streams app.
> > >
> > > That might be too radical, and maybe the problem isn't worth the burden
> > of
> > > forcing users to change their code and replace the config with actual
> > Serde
> > > objects. But it should be an easy change to make, and if it isn't,
> that's
> > > probably a good sign that you're using the serde incorrectly somewhere.
> > >
> > > If we don't deprecate the default.windowed.serde.inner.class, then it's
> > > less clear
> > > to me how to proceed. The only really consistent thing to do seems to
> be
> > to
> > > name and position the new window size config as a default config and
> > allow
> > > it to be used similar to the default inner class configs. Which, as
> > > established
> > > throughout this discussion, seems very very wrong
> > >
> > > So yes, I think we should just stick with the original name
> > window.size.ms
> > > .
> > > Or
> > > better yet, call it windowed.deserializer.window.size.ms and name the
> > > default.windowed.serde.inner.class replacements
> > > windowed.deserializer.inner.class and windowed.serializer.inner.class
> > >
> > > On Tue, Sep 8, 2020 at 2:07 PM Matthias J. Sax 
> wrote:
> > >
> > > > From my understanding, the KIP aims for the case when a user does not
> > > > control the code, eg, when using the command line consumer (or
> similar
> > > > tools).
> > > >
> > > > If the user writes code, we should always encourage her to
> instantiate
> > > > the deserializer explicitly and not relying on reflection+config.
> > > >
> > > > I also don't think that the `default` prefix does make sense, as it
> > > > indicates that there might be a non-default. However, IMHO, we should
> > > > not allow "overwrite semantics" but rather throw an exception if the
> > > > config is set and a window size is provided via the constructor. We
> > > > should not allow to mix-and-match both and

Re: [DISCUSS] KIP-691: Transactional Producer Exception Handling

2021-01-18 Thread Guozhang Wang

Hello Boyang,

Thanks for the updated KIP. I read it again and have the following thoughts:

0. I'm a bit concerned that if commitTxn does not throw any non-fatal
exception, and instead we rely on the subsequent beginTxn call to throw, it
may violate some callers with a pattern that relying on commitTxn to
succeed to make some non-rollback operations. For example:

beginTxn()
// do some read-write on my local DB
commitTxn()
// if commitTxn succeeds, then commit the DB

-

The issue is that, committing DB is a non-rollback operation, and users may
just rely on commitTxn to return without error to make this non-rollback
call. Of course we can just claim this pattern is not legitimate and is not
the right way of doing things, but many users may naturally adopt this
pattern.

So maybe we should still let commitTxn also throw non-fatal exceptions, in
which case we would then call abortTxn again.

But if we do this, the pattern becomes:

try {
   beginTxn()
   // do something
} catch (Exception) {
   shouldCommit = false;
}

if (shouldCommit) {
try {
commitTxn()
} catch (...) {// enumerate all fatal exceptions
shutdown()
} catch (KafkaException) {
// non-fatal
shouldCommit = false;
}
}

if (!shouldCommit && running()) {
try {
abortTxn()
} catch (KafkaException) {
// only throw fatal
shutdown()
}
}

-

Which is much more complicated.

Thank makes me think, the alternative we have discussed offline may be
better: let commitTxn() to return a boolean flag.

* If it returns true, it means the commit succeeded. Users can comfortably
continue and do any external non-rollback operations if they like.
* If it returns false, it means the commit failed with non-fatal error *AND
the txn has been aborted*. Users do not need to call abortTxn again.
* If it throws, then it means fatal errors. Users should shut down the
client.

In this case, the pattern becomes:

try {
   beginTxn()
   // do something
} catch (Exception) {
   shouldCommit = false;
}

try {
if (shouldCommit) {
commitSucceeded = commitTxn()
} else {
// reset offsets, rollback operations, etc
abortTxn()
}
} catch (KafkaException) {
// only throw fatal
shutdown()
}

if (commitSucceeded)
   // do other non-rollbackable things
else
   // reset offsets, rollback operations, etc

-

Of course, if we want to have better visibility into what caused the commit
to fail and txn to abort. We can let the return type be an enum instead of
a flag. But my main idea is to still let the commitTxn be the final point
users can tell whether this txn succeeded or not, instead of relying on the
next beginTxn() call.

1. Re: "while maintaining the behavior to throw fatal exception in raw" not
sure what do you mean by "throw" here. Are you proposing the callback would
*pass* (not throw) in any fatal exceptions when triggered without wrapping?

2. I'm not sure I understand the claim regarding the callback that "In EOS
setup, it is not required to handle the exception". Are you proposing that,
e.g. in Streams, we do not try to handle any exceptions if EOS is enabled
in the callback anymore, but just let commitTxn() itself to fail to be
notified about the problem? Personally I think in Streams we should just
make the handling logic of the callback to be consistent regardless of the
EOS settings (today we have different logic depending on this logic, which
I think could be unified as well).

Guozhang

On Thu, Dec 17, 2020 at 8:42 PM Boyang Chen 
wrote:

> Thanks for everyone's feedback so far. I have polished the KIP after
> offline discussion with some folks working on EOS to make the exception
> handling more lightweight. The essential change is that we are not
> inventing a new intermediate exception type, but instead separating a full
> transaction into two phases:
>
> 1. The data transmission phase
> 2. The commit phase
>
> This way for any exception thrown from phase 1, will be an indicator in
> phase 2 whether we should do commit or abort, and from now on
> `commitTransaction` should only throw fatal exceptions, similar to
> `abortTransaction`, so that any KafkaException caught in the commit phase
> will be definitely fatal to crash the app. For more advanced users such as
> Streams, we have the ability to further wrap selected types of fatal
> exceptions to trigger task migration if necessary.
>
> More details in the KIP, feel free to take another look, thanks!
>
> On Thu, Dec 17, 2020 at 8:36 PM Boyang Chen 
> wrote:
>
> > Thanks Bruno for the feedback.
> >
> > On Mon, Dec 7, 2020 at 5:26 AM Bruno Cadonna  wrote:
> >
> >> Thanks Boyang for the KIP!
> >>
> >> Like Matthias, I do also not know the producer internal well enough to
> >> comment on the categorization. However, I think having a super exception
> >> (e.g. RetriableException) that  encodes if an exception is fatal or not
> >> is clean

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #424

2021-01-18 Thread Apache Jenkins Server

See 


Changes:

[github] KAFKA-10841: Extract conversion from LogReadResult to 
FetchPartitionData (#9743)


--
[...truncated 3.58 MB...]
ConsumerRecordFactoryTest > shouldNotAllowToCreateTopicWithNullHeaders() PASSED

ConsumerRecordFactoryTest > 
shouldNotAllowToCreateTopicWithNullTopicNameWithDefaultTimestamp() STARTED

ConsumerRecordFactoryTest > 
shouldNotAllowToCreateTopicWithNullTopicNameWithDefaultTimestamp() PASSED

ConsumerRecordFactoryTest > 
shouldRequireCustomTopicNameIfNotDefaultFactoryTopicName() STARTED

ConsumerRecordFactoryTest > 
shouldRequireCustomTopicNameIfNotDefaultFactoryTopicName() PASSED

ConsumerRecordFactoryTest > 
shouldRequireCustomTopicNameIfNotDefaultFactoryTopicNameWithNullKey() STARTED

ConsumerRecordFactoryTest > 
shouldRequireCustomTopicNameIfNotDefaultFactoryTopicNameWithNullKey() PASSED

ConsumerRecordFactoryTest > shouldCreateConsumerRecord() STARTED

ConsumerRecordFactoryTest > shouldCreateConsumerRecord() PASSED

ConsumerRecordFactoryTest > shouldCreateNullKeyConsumerRecord() STARTED

ConsumerRecordFactoryTest > shouldCreateNullKeyConsumerRecord() PASSED

ConsumerRecordFactoryTest > shouldCreateConsumerRecordWithOtherTopicName() 
STARTED

ConsumerRecordFactoryTest > shouldCreateConsumerRecordWithOtherTopicName() 
PASSED

ConsumerRecordFactoryTest > shouldAdvanceTime() STARTED

ConsumerRecordFactoryTest > shouldAdvanceTime() PASSED

ConsumerRecordFactoryTest > 
shouldNotAllowToCreateTopicWithNullTopicNameWithKeyValuePairs() STARTED

ConsumerRecordFactoryTest > 
shouldNotAllowToCreateTopicWithNullTopicNameWithKeyValuePairs() PASSED

ConsumerRecordFactoryTest > 
shouldRequireCustomTopicNameIfNotDefaultFactoryTopicNameWithKeyValuePairsAndCustomTimestamps()
 STARTED

ConsumerRecordFactoryTest > 
shouldRequireCustomTopicNameIfNotDefaultFactoryTopicNameWithKeyValuePairsAndCustomTimestamps()
 PASSED

ConsumerRecordFactoryTest > 
shouldRequireCustomTopicNameIfNotDefaultFactoryTopicNameWithKeyValuePairs() 
STARTED

ConsumerRecordFactoryTest > 
shouldRequireCustomTopicNameIfNotDefaultFactoryTopicNameWithKeyValuePairs() 
PASSED

ConsumerRecordFactoryTest > 
shouldCreateConsumerRecordWithOtherTopicNameAndTimestamp() STARTED

ConsumerRecordFactoryTest > 
shouldCreateConsumerRecordWithOtherTopicNameAndTimestamp() PASSED

ConsumerRecordFactoryTest > 
shouldNotAllowToCreateTopicWithNullTopicNameWithKeyValuePairsAndCustomTimestamps()
 STARTED

ConsumerRecordFactoryTest > 
shouldNotAllowToCreateTopicWithNullTopicNameWithKeyValuePairsAndCustomTimestamps()
 PASSED

ConsumerRecordFactoryTest > shouldNotAllowToCreateTopicWithNullTopicName() 
STARTED

ConsumerRecordFactoryTest > shouldNotAllowToCreateTopicWithNullTopicName() 
PASSED

ConsumerRecordFactoryTest > 
shouldCreateConsumerRecordsFromKeyValuePairsWithCustomTimestampAndIncrementsAndNotAdvanceTime()
 STARTED

ConsumerRecordFactoryTest > 
shouldCreateConsumerRecordsFromKeyValuePairsWithCustomTimestampAndIncrementsAndNotAdvanceTime()
 PASSED

ConsumerRecordFactoryTest > 
shouldCreateNullKeyConsumerRecordWithTimestampWithTimestamp() STARTED

ConsumerRecordFactoryTest > 
shouldCreateNullKeyConsumerRecordWithTimestampWithTimestamp() PASSED

ConsumerRecordFactoryTest > 
shouldRequireCustomTopicNameIfNotDefaultFactoryTopicNameWithNullKeyAndDefaultTimestamp()
 STARTED

ConsumerRecordFactoryTest > 
shouldRequireCustomTopicNameIfNotDefaultFactoryTopicNameWithNullKeyAndDefaultTimestamp()
 PASSED

ConsumerRecordFactoryTest > 
shouldCreateConsumerRecordsFromKeyValuePairsWithTimestampAndIncrements() STARTED

ConsumerRecordFactoryTest > 
shouldCreateConsumerRecordsFromKeyValuePairsWithTimestampAndIncrements() PASSED

> Task :streams:upgrade-system-tests-0100:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-0100:testClasses
> Task :streams:upgrade-system-tests-0100:checkstyleTest
> Task :streams:upgrade-system-tests-0100:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-0100:test
> Task :streams:upgrade-system-tests-0101:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-0101:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-0101:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-0101:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-0101:compileTestJava
> Task :streams:upgrade-system-tests-0101:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-0101:testClasses
> Task :streams:upgrade-system-tests-0101:checkstyleTest
> Task :streams:upgrade-system-tests-0101:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-0101:test
> Task :streams:upgrade-system-tests-0102:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-0102:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-0102:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-0102:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-0102:compil

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #376

2021-01-18 Thread Apache Jenkins Server

See 


Changes:

[github] KAFKA-10841: Extract conversion from LogReadResult to 
FetchPartitionData (#9743)


--
[...truncated 3.55 MB...]
MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@cb27936, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@cb27936, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@12d0f0c0, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@12d0f0c0, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@51eb9dbb, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@51eb9dbb, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@543c312, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@543c312, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@40756d78, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@40756d78, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@456ed62a, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@456ed62a, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@5fb73970, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@5fb73970, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@154b0f65, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@154b0f65, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@46c84559, 
timestamped = false, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@46c84559, 
timestamped = false, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@529b7eea, 
timestamped = false, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@529b7eea, 
timestamped = false, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@1d7d288b, 
timestamped = false, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@1d7d288b, 
timestamped = false, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@731751c3, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@731751c3, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@132487f4, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@132487f4, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #405

2021-01-18 Thread Apache Jenkins Server

See 


Changes:

[github] KAFKA-10841: Extract conversion from LogReadResult to 
FetchPartitionData (#9743)


--
[...truncated 3.58 MB...]
OutputVerifierTest > 
shouldPassIfKeyAndValueAndTimestampIsEqualForCompareKeyValueTimestamp() STARTED

OutputVerifierTest > 
shouldPassIfKeyAndValueAndTimestampIsEqualForCompareKeyValueTimestamp() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullReversForCompareKeyValueWithProducerRecord() 
STARTED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullReversForCompareKeyValueWithProducerRecord() 
PASSED

OutputVerifierTest > 
shouldPassIfKeyAndValueIsEqualWithNullForCompareKeyValueWithProducerRecord() 
STARTED

OutputVerifierTest > 
shouldPassIfKeyAndValueIsEqualWithNullForCompareKeyValueWithProducerRecord() 
PASSED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > shouldFailIfValueIsDifferentForCompareKeyValueTimestamp() 
STARTED

OutputVerifierTest > shouldFailIfValueIsDifferentForCompareKeyValueTimestamp() 
PASSED

OutputVerifierTest > 
shouldPassIfValueAndTimestampIsEqualForCompareValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldPassIfValueAndTimestampIsEqualForCompareValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueTimestamp() STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueTimestamp() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReverseForCompareValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReverseForCompareValueTimestampWithProducerRecord()
 PASSED

KeyValueStoreFacadeTest > shouldReturnIsOpen() STARTED

KeyValueStoreFacadeTest > shouldReturnIsOpen() PASSED

KeyValueStoreFacadeTest > shouldDeleteAndReturnPlainValue() STARTED

KeyValueStoreFacadeTest > shouldDeleteAndReturnPlainValue() PASSED

KeyValueStoreFacadeTest > shouldReturnName() STARTED

KeyValueStoreFacadeTest > shouldReturnName() PASSED

KeyValueStoreFacadeTest > shouldPutWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldPutAllWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutAllWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldReturnIsPersistent() STARTED

KeyValueStoreFacadeTest > shouldReturnIsPersistent() PASSED

KeyValueStoreFacadeTest > shouldForwardDeprecatedInit() STARTED

KeyValueStoreFacadeTest > shouldForwardDeprecatedInit() PASSED

KeyValueStoreFacadeTest > shouldPutIfAbsentWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutIfAbsentWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldForwardClose() STARTED

KeyValueStoreFacadeTest > shouldForwardClose() PASSED

KeyValueStoreFacadeTest > shouldForwardFlush() STARTED

KeyValueStoreFacadeTest > shouldForwardFlush() PASSED

KeyValueStoreFacadeTest > shouldForwardInit() STARTED

KeyValueStoreFacadeTest > shouldForwardInit() PASSED

> Task :streams:upgrade-system-tests-0101:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-0101:testClasses
> Task :streams:upgrade-system-tests-0101:checkstyleTest
> Task :streams:upgrade-system-tests-0101:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-0101:test
> Task :streams:upgrade-system-tests-0102:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-0102:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-0102:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-0102:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-0102:compileTestJava
> Task :streams:upgrade-system-tests-0102:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-0102:testClasses
> Task :streams:upgrade-system-tests-0102:checkstyleTest
> Task :streams:upgrade-system-tests-0102:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-0102:test
> Task :streams:upgrade-system-tests-0110:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-0110:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-0110:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-0110:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-0110:compileTestJava
> Task :streams:upgrade-system-tests-0110:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-0110:testClasses
> Task :streams:upgrade-system-tests-0110:checkstyleTest
> Ta

[jira] [Resolved] (KAFKA-10841) LogReadResult should be able to converted to FetchPartitionData

2021-01-18 Thread Ismael Juma (Jira)



 [ 
https://issues.apache.org/jira/browse/KAFKA-10841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ismael Juma resolved KAFKA-10841.
-
Fix Version/s: 2.8.0
   Resolution: Fixed

> LogReadResult should be able to converted to FetchPartitionData 
> 
>
> Key: KAFKA-10841
> URL: https://issues.apache.org/jira/browse/KAFKA-10841
> Project: Kafka
>  Issue Type: Improvement
>Reporter: Chia-Ping Tsai
>Assignee: GeordieMai
>Priority: Minor
>  Labels: newbie
> Fix For: 2.8.0
>
>
> There are duplicate code which try to convert LogReadResult to 
> FetchPartitionData. It seems to me the duplicate code can be eliminated by 
> moving the conversion to LogReadResult.
> occurrence 1: 
> https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/ReplicaManager.scala#L1076
> occurrence 2:
> https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/DelayedFetch.scala#L189
>   



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #423

2021-01-18 Thread Apache Jenkins Server

See 


Changes:

[github] MINOR: Use Gradle's JUnitPlatform for upgrade-system-tests modules 
(#9922)

[github] MINOR: Upgrade gradle to 6.8 and test retry plugin to 1.2.0 (#9849)


--
[...truncated 3.58 MB...]

TestTopicsTest > testValue() STARTED

TestTopicsTest > testValue() PASSED

TestTopicsTest > testTimestampAutoAdvance() STARTED

TestTopicsTest > testTimestampAutoAdvance() PASSED

TestTopicsTest > testOutputWrongSerde() STARTED

TestTopicsTest > testOutputWrongSerde() PASSED

TestTopicsTest > shouldNotAllowToCreateOutputTopicWithNullTopicName() STARTED

TestTopicsTest > shouldNotAllowToCreateOutputTopicWithNullTopicName() PASSED

TestTopicsTest > testWrongSerde() STARTED

TestTopicsTest > testWrongSerde() PASSED

TestTopicsTest > testKeyValuesToMapWithNull() STARTED

TestTopicsTest > testKeyValuesToMapWithNull() PASSED

TestTopicsTest > testNonExistingOutputTopic() STARTED

TestTopicsTest > testNonExistingOutputTopic() PASSED

TestTopicsTest > testMultipleTopics() STARTED

TestTopicsTest > testMultipleTopics() PASSED

TestTopicsTest > testKeyValueList() STARTED

TestTopicsTest > testKeyValueList() PASSED

TestTopicsTest > shouldNotAllowToCreateOutputWithNullDriver() STARTED

TestTopicsTest > shouldNotAllowToCreateOutputWithNullDriver() PASSED

TestTopicsTest > testValueList() STARTED

TestTopicsTest > testValueList() PASSED

TestTopicsTest > testRecordList() STARTED

TestTopicsTest > testRecordList() PASSED

TestTopicsTest > testNonExistingInputTopic() STARTED

TestTopicsTest > testNonExistingInputTopic() PASSED

TestTopicsTest > testKeyValuesToMap() STARTED

TestTopicsTest > testKeyValuesToMap() PASSED

TestTopicsTest > testRecordsToList() STARTED

TestTopicsTest > testRecordsToList() PASSED

TestTopicsTest > testKeyValueListDuration() STARTED

TestTopicsTest > testKeyValueListDuration() PASSED

TestTopicsTest > testInputToString() STARTED

TestTopicsTest > testInputToString() PASSED

TestTopicsTest > testTimestamp() STARTED

TestTopicsTest > testTimestamp() PASSED

TestTopicsTest > testWithHeaders() STARTED

TestTopicsTest > testWithHeaders() PASSED

TestTopicsTest > testKeyValue() STARTED

TestTopicsTest > testKeyValue() PASSED

TestTopicsTest > shouldNotAllowToCreateTopicWithNullTopicName() STARTED

TestTopicsTest > shouldNotAllowToCreateTopicWithNullTopicName() PASSED

> Task :streams:upgrade-system-tests-0102:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-0102:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-0102:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-0102:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-0102:compileTestJava
> Task :streams:upgrade-system-tests-0102:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-0102:testClasses
> Task :streams:upgrade-system-tests-0102:checkstyleTest
> Task :streams:upgrade-system-tests-0102:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-0102:test
> Task :streams:upgrade-system-tests-0110:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-0110:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-0110:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-0110:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-0110:compileTestJava
> Task :streams:upgrade-system-tests-0110:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-0110:testClasses
> Task :streams:upgrade-system-tests-0110:checkstyleTest
> Task :streams:upgrade-system-tests-0110:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-0110:test
> Task :streams:upgrade-system-tests-10:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-10:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-10:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-10:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-10:compileTestJava
> Task :streams:upgrade-system-tests-10:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-10:testClasses
> Task :streams:upgrade-system-tests-10:checkstyleTest
> Task :streams:upgrade-system-tests-10:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-10:test
> Task :streams:upgrade-system-tests-11:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-11:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-11:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-11:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-11:compileTestJava
> Task :streams:upgrade-system-tests-11:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-11:testClasses
> Task :streams:upgrade-system-tests-11:checkstyleTest
> Task :streams:upgrade-system-tests-11:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-11:test
> Task :streams:upgrade-system-tests-20:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-20:processResources N

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #375

2021-01-18 Thread Apache Jenkins Server

See 


Changes:

[github] MINOR: Use Gradle's JUnitPlatform for upgrade-system-tests modules 
(#9922)

[github] MINOR: Upgrade gradle to 6.8 and test retry plugin to 1.2.0 (#9849)


--
[...truncated 3.56 MB...]

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@19a7435a,
 timestamped = true, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3be16fd5,
 timestamped = true, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@3be16fd5,
 timestamped = true, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@7b48240b,
 timestamped = true, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@7b48240b,
 timestamped = true, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@1b3747e2,
 timestamped = true, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.TimestampedWindowStoreBuilder@1b3747e2,
 timestamped = true, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@6dab6198, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@6dab6198, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@2b501aa7, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@2b501aa7, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@608440e3, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@608440e3, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@4ed825a1, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@4ed825a1, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@3583f62, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@3583f62, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@33f45d6d, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@33f45d6d, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@55836474, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@55836474, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@4909, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@4909, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@481f8e4d, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@481f8e4d, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #404

2021-01-18 Thread Apache Jenkins Server

See 


Changes:

[github] KAFKA-7341 Migrate core module to JUnit 5 (#9855)

[github] KAFKA-12221 remove PowerMock from connect-json module and 
connect-transforms module (#9924)

[github] MINOR: Use Gradle's JUnitPlatform for upgrade-system-tests modules 
(#9922)

[github] MINOR: Upgrade gradle to 6.8 and test retry plugin to 1.2.0 (#9849)


--
[...truncated 3.58 MB...]
OutputVerifierTest > 
shouldPassIfKeyAndValueAndTimestampIsEqualWithNullForCompareKeyValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldPassIfKeyAndValueAndTimestampIsEqualWithNullForCompareKeyValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareKeyValueWithProducerRecord() 
STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareKeyValueWithProducerRecord() 
PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentForCompareKeyValueTimestampWithProducerRecord() 
STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentForCompareKeyValueTimestampWithProducerRecord() 
PASSED

OutputVerifierTest > 
shouldNotAllowNullProducerRecordWithExpectedRecordForCompareValueTimestamp() 
STARTED

OutputVerifierTest > 
shouldNotAllowNullProducerRecordWithExpectedRecordForCompareValueTimestamp() 
PASSED

OutputVerifierTest > shouldNotAllowNullExpectedRecordForCompareValue() STARTED

OutputVerifierTest > shouldNotAllowNullExpectedRecordForCompareValue() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > shouldNotAllowNullProducerRecordForCompareKeyValue() 
STARTED

OutputVerifierTest > shouldNotAllowNullProducerRecordForCompareKeyValue() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueWithProducerRecord()
 PASSED

OutputVerifierTest > 
shouldPassIfKeyAndValueAndTimestampIsEqualForCompareKeyValueTimestamp() STARTED

OutputVerifierTest > 
shouldPassIfKeyAndValueAndTimestampIsEqualForCompareKeyValueTimestamp() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullReversForCompareKeyValueWithProducerRecord() 
STARTED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullReversForCompareKeyValueWithProducerRecord() 
PASSED

OutputVerifierTest > 
shouldPassIfKeyAndValueIsEqualWithNullForCompareKeyValueWithProducerRecord() 
STARTED

OutputVerifierTest > 
shouldPassIfKeyAndValueIsEqualWithNullForCompareKeyValueWithProducerRecord() 
PASSED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfKeyIsDifferentWithNullForCompareKeyValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > shouldFailIfValueIsDifferentForCompareKeyValueTimestamp() 
STARTED

OutputVerifierTest > shouldFailIfValueIsDifferentForCompareKeyValueTimestamp() 
PASSED

OutputVerifierTest > 
shouldPassIfValueAndTimestampIsEqualForCompareValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldPassIfValueAndTimestampIsEqualForCompareValueTimestampWithProducerRecord()
 PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueTimestamp() STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReversForCompareKeyValueTimestamp() PASSED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReverseForCompareValueTimestampWithProducerRecord()
 STARTED

OutputVerifierTest > 
shouldFailIfValueIsDifferentWithNullReverseForCompareValueTimestampWithProducerRecord()
 PASSED

MockProcessorContextAPITest > shouldStoreAndReturnStateStores() STARTED

MockProcessorContextAPITest > shouldStoreAndReturnStateStores() PASSED

MockProcessorContextAPITest > shouldCaptureOutputRecords() STARTED

MockProcessorContextAPITest > shouldCaptureOutputRecords() PASSED

MockProcessorContextAPITest > fullConstructorShouldSetAllExpectedAttributes() 
STARTED

MockProcessorContextAPITest > fullConstructorShouldSetAllExpectedAttributes() 
PASSED

MockProcessorContextAPITest > shouldCaptureCommitsAndAllowReset() STARTED

MockProcessorContextAPITest > shouldCaptureCommitsAndAllowReset() PASSED

MockProcessorContextAPITest > shouldCaptureApplicationAndRecordMetadata() 
STARTED

MockProcessorContextAPITest > shouldCaptureApplicationAndRecordMetadata() PASSED

MockProcessorContextAPITest > shouldCaptureRecordsOutputToChildByName() STA

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #422

2021-01-18 Thread Apache Jenkins Server

See 


Changes:

[github] KAFKA-7341 Migrate core module to JUnit 5 (#9855)

[github] KAFKA-12221 remove PowerMock from connect-json module and 
connect-transforms module (#9924)


--
[...truncated 3.58 MB...]
TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnWallClockTimeDeprecated() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnWallClockTimeDeprecated() 
PASSED

TopologyTestDriverAtLeastOnceTest > shouldProcessRecordForTopic() STARTED

TopologyTestDriverAtLeastOnceTest > shouldProcessRecordForTopic() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldForwardRecordsFromSubtopologyToSubtopology() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldForwardRecordsFromSubtopologyToSubtopology() PASSED

TopologyTestDriverAtLeastOnceTest > shouldNotUpdateStoreForSmallerValue() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldNotUpdateStoreForSmallerValue() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldCreateStateDirectoryForStatefulTopology() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldCreateStateDirectoryForStatefulTopology() PASSED

TopologyTestDriverAtLeastOnceTest > shouldNotRequireParameters() STARTED

TopologyTestDriverAtLeastOnceTest > shouldNotRequireParameters() PASSED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateIfWallClockTimeAdvances() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateIfWallClockTimeAdvances() 
PASSED

TestTopicsTest > testNonUsedOutputTopic() STARTED

TestTopicsTest > testNonUsedOutputTopic() PASSED

TestTopicsTest > testEmptyTopic() STARTED

TestTopicsTest > testEmptyTopic() PASSED

TestTopicsTest > testStartTimestamp() STARTED

TestTopicsTest > testStartTimestamp() PASSED

TestTopicsTest > testNegativeAdvance() STARTED

TestTopicsTest > testNegativeAdvance() PASSED

TestTopicsTest > shouldNotAllowToCreateWithNullDriver() STARTED

TestTopicsTest > shouldNotAllowToCreateWithNullDriver() PASSED

TestTopicsTest > testDuration() STARTED

TestTopicsTest > testDuration() PASSED

TestTopicsTest > testOutputToString() STARTED

TestTopicsTest > testOutputToString() PASSED

TestTopicsTest > testValue() STARTED

TestTopicsTest > testValue() PASSED

TestTopicsTest > testTimestampAutoAdvance() STARTED

TestTopicsTest > testTimestampAutoAdvance() PASSED

TestTopicsTest > testOutputWrongSerde() STARTED

TestTopicsTest > testOutputWrongSerde() PASSED

TestTopicsTest > shouldNotAllowToCreateOutputTopicWithNullTopicName() STARTED

TestTopicsTest > shouldNotAllowToCreateOutputTopicWithNullTopicName() PASSED

TestTopicsTest > testWrongSerde() STARTED

TestTopicsTest > testWrongSerde() PASSED

TestTopicsTest > testKeyValuesToMapWithNull() STARTED

TestTopicsTest > testKeyValuesToMapWithNull() PASSED

TestTopicsTest > testNonExistingOutputTopic() STARTED

TestTopicsTest > testNonExistingOutputTopic() PASSED

TestTopicsTest > testMultipleTopics() STARTED

TestTopicsTest > testMultipleTopics() PASSED

TestTopicsTest > testKeyValueList() STARTED

TestTopicsTest > testKeyValueList() PASSED

TestTopicsTest > shouldNotAllowToCreateOutputWithNullDriver() STARTED

TestTopicsTest > shouldNotAllowToCreateOutputWithNullDriver() PASSED

TestTopicsTest > testValueList() STARTED

TestTopicsTest > testValueList() PASSED

TestTopicsTest > testRecordList() STARTED

TestTopicsTest > testRecordList() PASSED

TestTopicsTest > testNonExistingInputTopic() STARTED

TestTopicsTest > testNonExistingInputTopic() PASSED

TestTopicsTest > testKeyValuesToMap() STARTED

TestTopicsTest > testKeyValuesToMap() PASSED

TestTopicsTest > testRecordsToList() STARTED

TestTopicsTest > testRecordsToList() PASSED

TestTopicsTest > testKeyValueListDuration() STARTED

TestTopicsTest > testKeyValueListDuration() PASSED

TestTopicsTest > testInputToString() STARTED

TestTopicsTest > testInputToString() PASSED

TestTopicsTest > testTimestamp() STARTED

TestTopicsTest > testTimestamp() PASSED

TestTopicsTest > testWithHeaders() STARTED

TestTopicsTest > testWithHeaders() PASSED

TestTopicsTest > testKeyValue() STARTED

TestTopicsTest > testKeyValue() PASSED

TestTopicsTest > shouldNotAllowToCreateTopicWithNullTopicName() STARTED

TestTopicsTest > shouldNotAllowToCreateTopicWithNullTopicName() PASSED

> Task :streams:upgrade-system-tests-21:processTestResources NO-SOURCE
> Task :streams:upgrade-system-tests-21:testClasses
> Task :streams:upgrade-system-tests-21:checkstyleTest
> Task :streams:upgrade-system-tests-21:spotbugsMain NO-SOURCE
> Task :streams:upgrade-system-tests-21:test
> Task :streams:upgrade-system-tests-22:compileJava NO-SOURCE
> Task :streams:upgrade-system-tests-22:processResources NO-SOURCE
> Task :streams:upgrade-system-tests-22:classes UP-TO-DATE
> Task :streams:upgrade-system-tests-22:checkstyleMain NO-SOURCE
> Task :streams:upgrade-system-tests-22:compileTestJava
> Task :streams:upgrade-system-tests-22:processTestResources NO-SOURCE
> Task

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #374

2021-01-18 Thread Apache Jenkins Server

See 


Changes:

[github] KAFKA-7341 Migrate core module to JUnit 5 (#9855)

[github] KAFKA-12221 remove PowerMock from connect-json module and 
connect-transforms module (#9924)


--
[...truncated 3.55 MB...]

TopologyTestDriverAtLeastOnceTest > shouldNotRequireParameters() PASSED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateIfWallClockTimeAdvances() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateIfWallClockTimeAdvances() 
PASSED

TopologyTestDriverEosTest > shouldReturnCorrectPersistentStoreTypeOnly() PASSED

TopologyTestDriverEosTest > shouldRespectTaskIdling() STARTED

TopologyTestDriverEosTest > shouldRespectTaskIdling() PASSED

TopologyTestDriverEosTest > shouldUseSourceSpecificDeserializers() STARTED

TopologyTestDriverEosTest > shouldUseSourceSpecificDeserializers() PASSED

TopologyTestDriverEosTest > shouldReturnAllStores() STARTED

TopologyTestDriverEosTest > shouldReturnAllStores() PASSED

TopologyTestDriverEosTest > shouldNotCreateStateDirectoryForStatelessTopology() 
STARTED

TopologyTestDriverEosTest > shouldNotCreateStateDirectoryForStatelessTopology() 
PASSED

TopologyTestDriverEosTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() STARTED

TopologyTestDriverEosTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies() PASSED

TopologyTestDriverEosTest > shouldReturnAllStoresNames() STARTED

TopologyTestDriverEosTest > shouldReturnAllStoresNames() PASSED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() STARTED

TopologyTestDriverEosTest > 
shouldPassRecordHeadersIntoSerializersAndDeserializers() PASSED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() STARTED

TopologyTestDriverEosTest > shouldProcessConsumerRecordList() PASSED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() STARTED

TopologyTestDriverEosTest > shouldUseSinkSpecificSerializers() PASSED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() STARTED

TopologyTestDriverEosTest > shouldFlushStoreForFirstInput() PASSED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() STARTED

TopologyTestDriverEosTest > shouldProcessFromSourceThatMatchPattern() PASSED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() STARTED

TopologyTestDriverEosTest > shouldCaptureSinkTopicNamesIfWrittenInto() PASSED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() STARTED

TopologyTestDriverEosTest > shouldUpdateStoreForNewKey() PASSED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
STARTED

TopologyTestDriverEosTest > shouldSendRecordViaCorrectSourceTopicDeprecated() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTime() PASSED

TopologyTestDriverEosTest > shouldSetRecordMetadata() STARTED

TopologyTestDriverEosTest > shouldSetRecordMetadata() PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForLargerValue() PASSED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() STARTED

TopologyTestDriverEosTest > shouldReturnCorrectInMemoryStoreTypeOnly() PASSED

TopologyTestDriverEosTest > shouldThrowForMissingTime() STARTED

TopologyTestDriverEosTest > shouldThrowForMissingTime() PASSED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
STARTED

TopologyTestDriverEosTest > shouldCaptureInternalTopicNamesIfWrittenInto() 
PASSED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() STARTED

TopologyTestDriverEosTest > shouldPunctuateOnWallClockTimeDeprecated() PASSED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() STARTED

TopologyTestDriverEosTest > shouldProcessRecordForTopic() PASSED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
STARTED

TopologyTestDriverEosTest > shouldForwardRecordsFromSubtopologyToSubtopology() 
PASSED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() STARTED

TopologyTestDriverEosTest > shouldNotUpdateStoreForSmallerValue() PASSED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
STARTED

TopologyTestDriverEosTest > shouldCreateStateDirectoryForStatefulTopology() 
PASSED

TopologyTestDriverEosTest > shouldNotRequireParameters() STARTED

TopologyTestDriverEosTest > shouldNotRequireParameters() PASSED

TopologyTestDriverEosTest > shouldPunctuateIfWallClockTimeAdvances() STARTED

TopologyTestDriverEosTest > shouldPunctuateIfWallClockTimeAdvances() PASSED

WindowStoreFacadeTest > shouldReturnIsOpen() STARTED

WindowStoreFacadeTest > shouldReturnIsOpen() PASSED

WindowStoreFacadeTest > shouldReturnName() STARTED

WindowStoreFacadeTest > shouldReturnName() PASSED

WindowStoreFacadeTest > shouldPutWithUnknownT

Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #403

2021-01-18 Thread Apache Jenkins Server

See

[jira] [Resolved] (KAFKA-12221) remove PowerMock from connect-json module and connect-transforms module

2021-01-18 Thread Chia-Ping Tsai (Jira)



 [ 
https://issues.apache.org/jira/browse/KAFKA-12221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Chia-Ping Tsai resolved KAFKA-12221.

Resolution: Fixed

> remove PowerMock from connect-json module and connect-transforms module
> ---
>
> Key: KAFKA-12221
> URL: https://issues.apache.org/jira/browse/KAFKA-12221
> Project: Kafka
>  Issue Type: Sub-task
>Reporter: Chia-Ping Tsai
>Assignee: Chia-Ping Tsai
>Priority: Minor
>




--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #421

2021-01-18 Thread Apache Jenkins Server

See 


Changes:

[github] MINOR: Make data in FetchSnapshotRequest and FetchSnapshotRespponse 
private (#9820)


--
[...truncated 3.64 MB...]
MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@3c92629c, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@3c92629c, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@21fb80d8, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@21fb80d8, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@44682e2c, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@44682e2c, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@2da79b0e, 
timestamped = false, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@2da79b0e, 
timestamped = false, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@1d589526, 
timestamped = false, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@1d589526, 
timestamped = false, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@5e13ec8a, 
timestamped = false, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@5e13ec8a, 
timestamped = false, caching = false, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@bd9b7db, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@bd9b7db, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@7d431e9c, 
timestamped = false, caching = true, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@7d431e9c, 
timestamped = false, caching = true, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@6180ad61, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@6180ad61, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@670bb84a, 
timestamped = false, caching = true, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@670bb84a, 
timestamped = false, caching = true, logging = false PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@76728727, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@76728727, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@e520f0d, 
timestamped = false, caching = false, logging = true STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@e520f0d, 
timestamped = false, caching = false, logging = true PASSED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@22127cf1, 
timestamped = false, caching = false, logging = false STARTED

MockProcessorContextStateStoreTest > builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@22127cf1, 
timestamped = false, caching = false, logging = false PASSED

MockProcessorC

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #373

2021-01-18 Thread Apache Jenkins Server

See 


Changes:

[github] MINOR: Make data in FetchSnapshotRequest and FetchSnapshotRespponse 
private (#9820)


--
[...truncated 3.63 MB...]

TopologyTestDriverAtLeastOnceTest > shouldFlushStoreForFirstInput() STARTED

TopologyTestDriverAtLeastOnceTest > shouldFlushStoreForFirstInput() PASSED

TopologyTestDriverAtLeastOnceTest > shouldProcessFromSourceThatMatchPattern() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldProcessFromSourceThatMatchPattern() 
PASSED

TopologyTestDriverAtLeastOnceTest > shouldCaptureSinkTopicNamesIfWrittenInto() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldCaptureSinkTopicNamesIfWrittenInto() 
PASSED

TopologyTestDriverAtLeastOnceTest > shouldUpdateStoreForNewKey() STARTED

TopologyTestDriverAtLeastOnceTest > shouldUpdateStoreForNewKey() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldSendRecordViaCorrectSourceTopicDeprecated() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldSendRecordViaCorrectSourceTopicDeprecated() PASSED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnWallClockTime() STARTED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnWallClockTime() PASSED

TopologyTestDriverAtLeastOnceTest > shouldSetRecordMetadata() STARTED

TopologyTestDriverAtLeastOnceTest > shouldSetRecordMetadata() PASSED

TopologyTestDriverAtLeastOnceTest > shouldNotUpdateStoreForLargerValue() STARTED

TopologyTestDriverAtLeastOnceTest > shouldNotUpdateStoreForLargerValue() PASSED

TopologyTestDriverAtLeastOnceTest > shouldReturnCorrectInMemoryStoreTypeOnly() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldReturnCorrectInMemoryStoreTypeOnly() 
PASSED

TopologyTestDriverAtLeastOnceTest > shouldThrowForMissingTime() STARTED

TopologyTestDriverAtLeastOnceTest > shouldThrowForMissingTime() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldCaptureInternalTopicNamesIfWrittenInto() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldCaptureInternalTopicNamesIfWrittenInto() PASSED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnWallClockTimeDeprecated() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateOnWallClockTimeDeprecated() 
PASSED

TopologyTestDriverAtLeastOnceTest > shouldProcessRecordForTopic() STARTED

TopologyTestDriverAtLeastOnceTest > shouldProcessRecordForTopic() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldForwardRecordsFromSubtopologyToSubtopology() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldForwardRecordsFromSubtopologyToSubtopology() PASSED

TopologyTestDriverAtLeastOnceTest > shouldNotUpdateStoreForSmallerValue() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldNotUpdateStoreForSmallerValue() PASSED

TopologyTestDriverAtLeastOnceTest > 
shouldCreateStateDirectoryForStatefulTopology() STARTED

TopologyTestDriverAtLeastOnceTest > 
shouldCreateStateDirectoryForStatefulTopology() PASSED

TopologyTestDriverAtLeastOnceTest > shouldNotRequireParameters() STARTED

TopologyTestDriverAtLeastOnceTest > shouldNotRequireParameters() PASSED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateIfWallClockTimeAdvances() 
STARTED

TopologyTestDriverAtLeastOnceTest > shouldPunctuateIfWallClockTimeAdvances() 
PASSED

MockTimeTest > shouldGetNanosAsMillis() STARTED

MockTimeTest > shouldGetNanosAsMillis() PASSED

MockTimeTest > shouldSetStartTime() STARTED

MockTimeTest > shouldSetStartTime() PASSED

MockTimeTest > shouldNotAllowNegativeSleep() STARTED

MockTimeTest > shouldNotAllowNegativeSleep() PASSED

MockTimeTest > shouldAdvanceTimeOnSleep() STARTED

MockTimeTest > shouldAdvanceTimeOnSleep() PASSED

KeyValueStoreFacadeTest > shouldReturnIsOpen() STARTED

KeyValueStoreFacadeTest > shouldReturnIsOpen() PASSED

KeyValueStoreFacadeTest > shouldDeleteAndReturnPlainValue() STARTED

KeyValueStoreFacadeTest > shouldDeleteAndReturnPlainValue() PASSED

KeyValueStoreFacadeTest > shouldReturnName() STARTED

KeyValueStoreFacadeTest > shouldReturnName() PASSED

KeyValueStoreFacadeTest > shouldPutWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldPutAllWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutAllWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldReturnIsPersistent() STARTED

KeyValueStoreFacadeTest > shouldReturnIsPersistent() PASSED

KeyValueStoreFacadeTest > shouldForwardDeprecatedInit() STARTED

KeyValueStoreFacadeTest > shouldForwardDeprecatedInit() PASSED

KeyValueStoreFacadeTest > shouldPutIfAbsentWithUnknownTimestamp() STARTED

KeyValueStoreFacadeTest > shouldPutIfAbsentWithUnknownTimestamp() PASSED

KeyValueStoreFacadeTest > shouldForwardClose() STARTED

KeyValueStoreFacadeTest > shouldForwardClose() PASSED

KeyValueStoreFacadeTest > shouldForwardFlush() STARTED

KeyValueStoreFacadeTest > shouldForwardFlush() PASSED

KeyValueStoreFacadeTest > shouldForwardInit() STARTED

KeyValueStoreFacadeTe

[VOTE] KIP-692: Make AdminClient value object constructors public

2021-01-18 Thread Noa Resare

Let’s kick of a vote for this tiny little KIP, that holds the promise of 
simplifying testing for code that calls the Kafka admin API:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-692:+Make+AdminClient+value+object+constructors+public
 


Thanks,
Noa

Re: [DISCUSS] KIP-692: Make AdminClient value object constructors public

2021-01-18 Thread Noa Resare

With this wall of discussion having died down a bit of lately, I think it makes 
sense to bring this to a vote. I’ll start a separate thread ;)

/noa

> On 7 Dec 2020, at 19:26, Gwen Shapira  wrote:
> 
> Sounds like a good idea :)
> 
> At some point we may want to switch to builders - it gives you more
> flexibility in how you construct all those objects. But those two
> changes are unrelated.
> 
> On Thu, Dec 3, 2020 at 9:30 AM Noa Resare  wrote:
>> 
>> Hi there,
>> 
>> I finally got around to write up the KIP for a change I have wanted for some 
>> time:
>> 
>> KIP-692: Make AdminClient value object constructors public 
>> 
>> 
>> In essence: Let us encourage better patterns for testing by making it easier 
>> to mock AdminService.
>> 
>> I am looking forward to hearing your thoughts on this.
>> 
>> Cheers
>> noa
> 
> 
> 
> -- 
> Gwen Shapira
> Engineering Manager | Confluent
> 650.450.2760 | @gwenshap
> Follow us: Twitter | blog

[jira] [Created] (KAFKA-12223) Consider not to Treat Mixed Usage of Shared and Dedicated Block Caches among RocksDB State Stores as Illegal State

2021-01-18 Thread Bruno Cadonna (Jira)

Bruno Cadonna created KAFKA-12223:
-

 Summary: Consider not to Treat Mixed Usage of Shared and Dedicated 
Block Caches among RocksDB State Stores as Illegal State
 Key: KAFKA-12223
 URL: https://issues.apache.org/jira/browse/KAFKA-12223
 Project: Kafka
  Issue Type: Bug
  Components: streams
Affects Versions: 2.7.0
Reporter: Bruno Cadonna


Currently, for the recording of properties-based RocksDB metrics, we consider 
setups where some RocksDB state stores use a shared block cache and some other 
RocksDB state stores use dedicated block caches as an illegal state and we 
throw an \{{IllegalStateException}}. However, technically, it is possible to 
configure such a mixed setup through the RocksDB config setter and thus we 
should probably not consider it an illegal state. Allowing such a mixed setup 
would complicate the measurements of the block cache metrics.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12222) Unable to connect to Kafka SSL

2021-01-18 Thread Sachit Murarka (Jira)

Sachit Murarka created KAFKA-1:
--

 Summary: Unable to connect to Kafka SSL
 Key: KAFKA-1
 URL: https://issues.apache.org/jira/browse/KAFKA-1
 Project: Kafka
  Issue Type: Bug
  Components: consumer
Affects Versions: 2.2.0
Reporter: Sachit Murarka


 I am getting following error while reading messages from SSL enabled kafka. 



 org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake 
failed Caused by: 
[http://javax.net|https://t.co/rDy8kGUMNP?amp=1].ssl.SSLProtocolException: 
Unexpected handshake message: server_hello



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12221) remove PowerMock from connect-json module and connect-transforms module

2021-01-18 Thread Chia-Ping Tsai (Jira)

Chia-Ping Tsai created KAFKA-12221:
--

 Summary: remove PowerMock from connect-json module and 
connect-transforms module
 Key: KAFKA-12221
 URL: https://issues.apache.org/jira/browse/KAFKA-12221
 Project: Kafka
  Issue Type: Sub-task
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai






--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12220) Replace PowerMock by Mockito

2021-01-18 Thread Chia-Ping Tsai (Jira)

Chia-Ping Tsai created KAFKA-12220:
--

 Summary: Replace PowerMock by Mockito
 Key: KAFKA-12220
 URL: https://issues.apache.org/jira/browse/KAFKA-12220
 Project: Kafka
  Issue Type: Improvement
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai


We are migrating project from junit 4 to junit 5 (KAFKA-7339). PowerMock, 
however, does not support junit 5 totally 
(https://github.com/powermock/powermock/issues/830). Hence, we ought to replace 
PowerMock by Mockito before migrating to junit 5 since rewriting all tests 
which are depending on PowerMock can bring a bunch of changes.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Created] (KAFKA-12219) Potential race condition in InMemoryKeyValueStore

2021-01-18 Thread Dongjin Lee (Jira)

Dongjin Lee created KAFKA-12219:
---

 Summary: Potential race condition in InMemoryKeyValueStore
 Key: KAFKA-12219
 URL: https://issues.apache.org/jira/browse/KAFKA-12219
 Project: Kafka
  Issue Type: Bug
  Components: streams
Reporter: Dongjin Lee
Assignee: Dongjin Lee


With KAFKA-8802 (included in [2.4.0 
release|https://downloads.apache.org/kafka/2.4.0/RELEASE_NOTES.html]), 
{{ConcurrentSkipListMap}} in {{InMemoryKeyValueStore}} was reverted into 
{{TreeMap}} for performance issues. However, the {{synchronized}} keyword for 
{{reverseRange}}, {{reverseAll}} methods were omitted, leaving possibility of 
race condition.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Re: [DISCUSS] KIP-705: Selectively Disable Topology Optimizations

Re: [VOTE] KIP-659: Improve TimeWindowedDeserializer and TimeWindowedSerde to handle window size

Re: [DISCUSS] KIP-691: Transactional Producer Exception Handling

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #424

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #376

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #405

[jira] [Resolved] (KAFKA-10841) LogReadResult should be able to converted to FetchPartitionData

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #423

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #375

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #404

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #422

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #374

Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #403

[jira] [Resolved] (KAFKA-12221) remove PowerMock from connect-json module and connect-transforms module

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #421

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #373

[VOTE] KIP-692: Make AdminClient value object constructors public

Re: [DISCUSS] KIP-692: Make AdminClient value object constructors public

[jira] [Created] (KAFKA-12223) Consider not to Treat Mixed Usage of Shared and Dedicated Block Caches among RocksDB State Stores as Illegal State

[jira] [Created] (KAFKA-12222) Unable to connect to Kafka SSL

[jira] [Created] (KAFKA-12221) remove PowerMock from connect-json module and connect-transforms module

[jira] [Created] (KAFKA-12220) Replace PowerMock by Mockito

[jira] [Created] (KAFKA-12219) Potential race condition in InMemoryKeyValueStore

23 matches

Site Navigation

Mail list logo

Footer information