[jira] [Resolved] (KAFKA-12795) Create kafka connector use chinese character failed

[pengWei Dou (Jira)]

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

pengWei Dou resolved KAFKA-12795.
-
Resolution: Won't Fix

> Create kafka connector use chinese character failed
> ---
>
> Key: KAFKA-12795
> URL: https://issues.apache.org/jira/browse/KAFKA-12795
> Project: Kafka
>  Issue Type: Bug
>  Components: core
>Affects Versions: 2.4.0
>Reporter: pengWei Dou
>Priority: Major
>
> In distribute mode(More than one node). using Chinese as the name of the 
> Connector causes the creation to fail. because RestClient code not set http 
> header encode to utf8.



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

[jira] [Created] (KAFKA-13076) cannot consumer

[label (Jira)]

label created KAFKA-13076:
-

 Summary: cannot consumer
 Key: KAFKA-13076
 URL: https://issues.apache.org/jira/browse/KAFKA-13076
 Project: Kafka
  Issue Type: Bug
  Components: consumer
Affects Versions: 2.7.0
Reporter: label
 Attachments: image-2021-07-13-15-25-42-375.png

After kafka (kafka_2.12-2.7.0) restarts, it can produce or consume.

 

The product send one message "1"

then sees that the log file is being added and the file is increasing,

but the consumer is always unable to connect.

 

ConsumerErrorMsg:
[2021-07-08 17:30:39,981] WARN [Consumer 
clientId=consumer-debug_producer_group-1, groupId=debug_producer_group] Error 
while fetching metadata with correlation id 2 : 
\{debug_producer=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
 
 

!image-2021-07-13-15-25-42-375.png!



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

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.0 #19

[Apache Jenkins Server]

See 

ScalaDocs Location

[Josep Prat]

Hi there,
While testing Scala 3 support I realized there are some warnings while
generating Scaladoc and Javadoc. I wanted to check the impact of the
warnings on the generated Scaladoc pages, but I couldn't find any link to
the Scaladoc pages. Can somebody point me to the right URL?
I'm happy to create a PR with the link on the right documentation pages
(like
https://kafka.apache.org/documentation/streams/developer-guide/dsl-api.html
and https://kafka.apache.org/documentation/#streamsapi).

Thanks in advance,

-- 

Josep Prat

*Aiven Deutschland GmbH*

Immanuelkirchstraße 26, 10405 Berlin

Amtsgericht Charlottenburg, HRB 209739 B

Geschäftsführer: Oskari Saarenmaa & Hannu Valtonen

*m:* +491715557497

*w:* aiven.io

*e:* josep.p...@aiven.io

[jira] [Created] (KAFKA-13077) Replication failing after unclean shutdown of ZK and all brokers

[Christopher Auston (Jira)]

Christopher Auston created KAFKA-13077:
--

 Summary: Replication failing after unclean shutdown of ZK and all 
brokers
 Key: KAFKA-13077
 URL: https://issues.apache.org/jira/browse/KAFKA-13077
 Project: Kafka
  Issue Type: Bug
Affects Versions: 2.8.0
Reporter: Christopher Auston


I am submitting this in the spirit of what can go wrong when an operator 
violates the constraints Kafka depends on. I don't know if Kafka could or 
should handle this more gracefully. I decided to file this issue because it was 
easy to get the problem I'm reporting with Kubernetes StatefulSets (STS). By 
"easy" I mean that I did not go out of my way to corrupt anything, I just was 
not careful when restarting ZK and brokers.

I violated the constraints of keeping Zookeeper stable and at least one running 
in-sync replica. 

I am running the bitnami/kafka helm chart on Amazon EKS.
{quote}% kubectl get po kaf-kafka-0 -ojson |jq .spec.containers'[].image'
"docker.io/bitnami/kafka:2.8.0-debian-10-r43"
{quote}
I started with 3 ZK instances and 3 brokers (both STS). I changed the 
cpu/memory requests on both STS and kubernetes proceeded to restart ZK and 
kafka instances at the same time. If I recall correctly there were some crashes 
and several restarts but eventually all the instances were running again. It's 
possible all ZK nodes and all brokers were unavailable at various points.

The problem I noticed was that two of the brokers were just continually 
spitting out messages like:
{quote}% kubectl logs kaf-kafka-0 --tail 10
[2021-07-13 14:26:08,871] INFO [ProducerStateManager 
partition=__transaction_state-0] Loading producer state from snapshot file 
'SnapshotFile(/bitnami/kafka/data/__transaction_state-0/0001.snapshot,1)'
 (kafka.log.ProducerStateManager)
[2021-07-13 14:26:08,871] WARN [Log partition=__transaction_state-0, 
dir=/bitnami/kafka/data] *Non-monotonic update of high watermark from 
(offset=2744 segment=[0:1048644]) to (offset=1 segment=[0:169])* (kafka.log.Log)
[2021-07-13 14:26:08,874] INFO [Log partition=__transaction_state-10, 
dir=/bitnami/kafka/data] Truncating to offset 2 (kafka.log.Log)
[2021-07-13 14:26:08,877] INFO [Log partition=__transaction_state-10, 
dir=/bitnami/kafka/data] Loading producer state till offset 2 with message 
format version 2 (kafka.log.Log)
[2021-07-13 14:26:08,877] INFO [ProducerStateManager 
partition=__transaction_state-10] Loading producer state from snapshot file 
'SnapshotFile(/bitnami/kafka/data/__transaction_state-10/0002.snapshot,2)'
 (kafka.log.ProducerStateManager)
[2021-07-13 14:26:08,877] WARN [Log partition=__transaction_state-10, 
dir=/bitnami/kafka/data] Non-monotonic update of high watermark from 
(offset=2930 segment=[0:1048717]) to (offset=2 segment=[0:338]) (kafka.log.Log)
[2021-07-13 14:26:08,880] INFO [Log partition=__transaction_state-20, 
dir=/bitnami/kafka/data] Truncating to offset 1 (kafka.log.Log)
[2021-07-13 14:26:08,882] INFO [Log partition=__transaction_state-20, 
dir=/bitnami/kafka/data] Loading producer state till offset 1 with message 
format version 2 (kafka.log.Log)
[2021-07-13 14:26:08,882] INFO [ProducerStateManager 
partition=__transaction_state-20] Loading producer state from snapshot file 
'SnapshotFile(/bitnami/kafka/data/__transaction_state-20/0001.snapshot,1)'
 (kafka.log.ProducerStateManager)
[2021-07-13 14:26:08,883] WARN [Log partition=__transaction_state-20, 
dir=/bitnami/kafka/data] Non-monotonic update of high watermark from 
(offset=2956 segment=[0:1048608]) to (offset=1 segment=[0:169]) (kafka.log.Log)
{quote}
If I describe that topic I can see that several partitions have a leader of 2 
and the ISR is just 2 (NOTE I added two more brokers and tried to reassign the 
topic onto brokers 2,3,4 which you can see below). The new brokers also spit 
out the messages about "non-monotonic update" just like the original followers. 
This describe output is from the following day.

{{% kafka-topics.sh ${=BS} -topic __transaction_state -describe}}
{{Topic: __transaction_state TopicId: i7bBNCeuQMWl-ZMpzrnMAw PartitionCount: 50 
ReplicationFactor: 3 Configs: 
compression.type=uncompressed,min.insync.replicas=3,cleanup.policy=compact,flush.ms=1000,segment.bytes=104857600,flush.messages=1,max.message.bytes=112,unclean.leader.election.enable=false,retention.bytes=1073741824}}
{{ Topic: __transaction_state Partition: 0 Leader: 2 Replicas: 4,3,2,1,0 Isr: 2 
Adding Replicas: 4,3 Removing Replicas: 1,0}}
{{ Topic: __transaction_state Partition: 1 Leader: 2 Replicas: 2,4,3 Isr: 
2,3,4}}
{{ Topic: __transaction_state Partition: 2 Leader: 3 Replicas: 3,2,4 Isr: 
2,3,4}}
{{ Topic: __transaction_state Partition: 3 Leader: 4 Replicas: 4,2,3 Isr: 
2,3,4}}
{{ Topic: __transaction_state Partition: 4 Leader: 2 Replicas: 2,3,4 Isr: 
2,3,4}}
{{ Topic: __transaction_state Partition: 5 Leader: 2 

Re: [VOTE] KIP-590: Redirect Zookeeper Mutation Protocols to The Controller

[Ron Dagostino]

Hi everyone.  I know it has been 9 months since the last message appeared
on this vote thread, but a potential oversight exists in the implementation
of DefaultKafkaPrincipalBuilder.KafkaPrincipalSerde from
https://github.com/apache/kafka/pull/9103.  Specifically, there is no magic
number at the top of the wire format, and this causes obscure parsing
errors if incompatible principal implementations are mixed.  A magic number
at the top would allow deserialization code to provide an intuitive error
message.  The current implementation (without a magic number) was released
in 2.8, but it presumably has never been used since forwarding is disabled (
https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/Kafka.scala#L73).
We would like to change the implementation to include a magic number at the
top for the 3.0 release.  This would be a breaking change, but again this
presumably has never been used anywhere in production and would therefore
break nothing.

Note that forwarding is always enabled for KRaft-based clusters, but such
clusters are not supported in any production sense and there is no upgrade
path from a 2.8 KRaft cluster to a 3.0 KRaft cluster (from
config/kraft/README.md: "KRaft mode in Kafka 2.8 is provided for testing
only, NOT for production. We do not yet support upgrading existing
ZooKeeper-based Kafka clusters into this mode. In fact, when Kafka 3.0 is
released, it will not be possible to upgrade your KRaft clusters from 2.8
to 3.0").

A PR to add the magic number appears at
https://github.com/apache/kafka/pull/11038.

Please respond to this thread if you have any concerns or objections.

Thanks,

Ron

On Fri, Oct 9, 2020 at 1:21 PM Boyang Chen 
wrote:

> Thanks Jason for the great thoughts, and we basically decided to shift the
> gear for a limited impersonation approach offline.
>
> The goal here is to simplify the handling logic by relying on the active
> controller to do the actual authorization for resources in the original
> client request. We are also adding the `KafkaPrincipalSerde` type to
> provide the functionality for principal serialization/deserialization so
> that it could embed in the Envelope and send to the active controller.
> Before 3.0, customized principal builders could optionally extend the serde
> type, which is required after 3.0 is released. Either way having the
> capability to serde KafkaPrincipal becomes a prerequisite to enable
> redirection besides IBP. Additionally, we add a forwardingPrincipal field
> to the Authorizer context for authorization and audit logging purposes,
> instead of going tagged fields in header.
>
> The KIP is updated to reflect the current approach, thanks.
>
>
>
> On Fri, Sep 25, 2020 at 5:55 PM Jason Gustafson 
> wrote:
>
> > Hey All,
> >
> > So the main thing the EnvelopeRequest gives us is a way to avoid
> converting
> > older API versions in order to attach the initial principal name and the
> > clientId. It also saves the need to add the initial principal and client
> id
> > as a tagged field to all of the forwarded protocols, which is nice. We
> > still have the challenge of advertising API versions which are compatible
> > with both the broker receiving the request and the controller that the
> > request is ultimately forwarded to, but not sure I see a way around that.
> >
> > I realize I might be walking into a minefield here, but since the
> envelope
> > is being revisited, it seems useful to compare the approach suggested
> above
> > with the option relying on impersonation. I favor the use of
> impersonation
> > because it makes forwarding simpler. As the proposal stands, we will have
> > to maintain logic for each forwarded API to unpack, authorize, and repack
> > any forwarded requests which flow through the broker. This is probably
> not
> > a huge concern from an efficiency perspective as long as we are talking
> > about just the Admin APIs, but it does have a big maintenance cost since
> > we'll need to ensure that every new field gets properly carried through.
> It
> > would be nice if we just didn't have to think about that. We also might
> > eventually come up with reasons to extend forwarding to non-admin APIs,
> so
> > it would be nice to start with an efficient approach.
> >
> > It seems like the main difference comes down to where the authorization
> is
> > done. Suppose that broker B receives an AlterConfig request from the
> client
> > in order to change topic configs and wants to forward to controller C.
> >
> > Option 1 (no impersonation): B authorizes AlterConfigs for the included
> > topics with the client principal. Rejected topics are stripped out of the
> > request.  Authorized topics are repackaged into a new request and sent in
> > an envelope to C, which verifies ClusterAction permission with the broker
> > principal and assumes authorization for the underlying request
> > Option 2 (with impersonation): B authenticates the client, but does no
> > authorization and forwards the request in 

Re: [DISCUSS] KIP-655: Windowed "Distinct" Operation for KStream

[Bruno Cadonna]

Hi,

Thanks for your comments, John!

1. equals() seems to be quite flexible in this case. I guess binary 
comparison would not work well if the timestamp is part of the value.


2. Then this seems to be a misunderstanding on my side. Ivan, could you 
please make this matter a bit clearer in the KIP? Actually, thinking 
about it again, I do currently not see why it should not make sense in 
hopping windows. Regarding this, I do not understand the following sentence:


"hopping and sliding windows do not make much sense for distinct() 
because they produce multiple intersected windows, so that one record 
can be multiplied instead of deduplication."


Ivan, what do you mean with "multiplied"?


Best,
Bruno

On 12.07.21 23:10, John Roesler wrote:

Hi all,

Bruno raised some very good points. I’d like to chime in with additional 
context.

1. Great point. We faced a similar problem defining KIP-557. For 557, we chose 
to use the serialized byte array instead of the equals() method, but I think 
the situation in KIP-655 is a bit different. I think it might make sense to use 
the equals() method here, but am curious what Ivan thinks.

2. I figured we'd do nothing. I thought Ivan was just saying that it doesn't 
make a ton of sense to use it, which I agree with, but it doesn't seem like 
that means we should prohibit it.

3. FWIW, I don't have a strong feeling either way.

Thanks,
-John

On Mon, Jul 12, 2021, at 09:14, Bruno Cadonna wrote:

Hi Ivan,

Thank you for the KIP!

Some aspects are not clear to me from the KIP and I have a proposal.

1. The KIP does not describe the criteria that define a duplicate. Could
you add a definition of duplicate to the KIP?

2. The KIP does not describe what happens if distinct() is applied on a
hopping window. On the DSL level, I do not see how you can avoid that
users apply distinct() on a hopping window, i.e., you cannot avoid it at
compile time, you need to check it at runtime and throw an exception. Is
this correct or am I missing something?

3. I would also like to back a proposal by Sophie. She proposed to use
deduplicate() instead of distinct(), since the other DSL operations are
also verbs. I do not think that SQL and the Java Stream API are good
arguments to not use a verb.

Best,
Bruno


On 10.07.21 19:11, John Roesler wrote:

Hi Ivan,

Sorry for the silence!

I have just re-read the proposal.

To summarize, you are now only proposing the zero-arg distict() method to be 
added to TimeWindowedKStream and SessionWindowedKStream, right?

I’m in favor of this proposal.

Thanks,
John

On Sat, Jul 10, 2021, at 10:18, Ivan Ponomarev wrote:

Hello everyone,

I would like to remind you about KIP-655 and KIP-759 just in case they
got lost in your inbox.

Now the initial proposal is split into two independent and smaller ones,
so it must be easier to review them. Of course, if you have time.

Regards,

Ivan


24.06.2021 18:11, Ivan Ponomarev пишет:

Hello all,

I have rewritten the KIP-655 summarizing what was agreed upon during
this discussion (now the proposal is much simpler and less invasive).

I have also created KIP-759 (cancelRepartition operation) and started a
discussion for it.

Regards,

Ivan.



04.06.2021 8:15, Matthias J. Sax пишет:

Just skimmed over the thread -- first of all, I am glad that we could
merge KIP-418 and ship it :)

About the re-partitioning concerns, there are already two tickets for it:

    - https://issues.apache.org/jira/browse/KAFKA-4835
    - https://issues.apache.org/jira/browse/KAFKA-10844

Thus, it seems best to exclude this topic from this KIP, and do a
separate KIP for it (if necessary, we can "pause" this KIP until the
repartition KIP is done). It's a long standing "issue" and we should
resolve it in a general way I guess.

(Did not yet ready all responses in detail yet, so keeping this comment
short.)


-Matthias

On 6/2/21 6:35 AM, John Roesler wrote:

Thanks, Ivan!

That sounds like a great plan to me. Two smaller KIPs are easier to
agree on than one big one.

I agree hopping and sliding windows will actually have a duplicating
effect. We can avoid adding distinct() to the sliding window
interface, but hopping windows are just a different parameterization
of epoch-aligned windows. It seems we can’t do much about that except
document the issue.

Thanks,
John

On Wed, May 26, 2021, at 10:14, Ivan Ponomarev wrote:

Hi John!

I think that your proposal is just fantastic, it simplifies things a
lot!

I also felt uncomfortable due to the fact that the proposed
`distinct()`
is not somewhere near `count()` and `reduce(..)`. But
`selectKey(..).groupByKey().windowedBy(..).distinct()` didn't look like
a correct option for  me because of the issue with the unneeded
repartitioning.

The bold idea that we can just CANCEL the repartitioning didn't came to
my mind.

What seemed to me a single problem is in fact two unrelated problems:
`distinct` operation and cancelling the unneeded repartitioning.

    > what if we introduce a parameter to `sele

[jira] [Created] (KAFKA-13078) Closing FileRawSnapshotWriter too early

[Jose Armando Garcia Sancio (Jira)]

Jose Armando Garcia Sancio created KAFKA-13078:
--

 Summary: Closing FileRawSnapshotWriter too early
 Key: KAFKA-13078
 URL: https://issues.apache.org/jira/browse/KAFKA-13078
 Project: Kafka
  Issue Type: Bug
  Components: kraft
Affects Versions: 3.0.0
Reporter: Jose Armando Garcia Sancio
Assignee: Jose Armando Garcia Sancio
 Fix For: 3.0.0


We are getting the following error
{code:java}
  [2021-07-13 17:23:42,174] ERROR [kafka-raft-io-thread]: Error due to 
(kafka.raft.KafkaRaftManager$RaftIoThread)
  java.io.UncheckedIOException: Error calculating snapshot size. temp path = 
/mnt/kafka/kafka-metadata-logs/@metadata-0/0062-02-3249768281228588378.checkpoint.part,
 snapshotId = OffsetAndEpoch(offset=62, epoch=2).
  at 
org.apache.kafka.snapshot.FileRawSnapshotWriter.sizeInBytes(FileRawSnapshotWriter.java:63)
  at 
org.apache.kafka.raft.KafkaRaftClient.maybeSendFetchOrFetchSnapshot(KafkaRaftClient.java:2044)
  at 
org.apache.kafka.raft.KafkaRaftClient.pollFollowerAsObserver(KafkaRaftClient.java:2032)
  at 
org.apache.kafka.raft.KafkaRaftClient.pollFollower(KafkaRaftClient.java:1995)
  at 
org.apache.kafka.raft.KafkaRaftClient.pollCurrentState(KafkaRaftClient.java:2104)
  at org.apache.kafka.raft.KafkaRaftClient.poll(KafkaRaftClient.java:2217)
  at kafka.raft.KafkaRaftManager$RaftIoThread.doWork(RaftManager.scala:52)
  at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:96)
  Caused by: java.nio.channels.ClosedChannelException
  at sun.nio.ch.FileChannelImpl.ensureOpen(FileChannelImpl.java:110)
  at sun.nio.ch.FileChannelImpl.size(FileChannelImpl.java:300)
  at 
org.apache.kafka.snapshot.FileRawSnapshotWriter.sizeInBytes(FileRawSnapshotWriter.java:60)
  ... 7 more
 {code}
This is because the {{FollowerState}} is closing the snapshot write passed 
through the argument instead of the one being replaced.



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

[jira] [Resolved] (KAFKA-13051) Require Principal Serde to be defined for 3.0

[Jason Gustafson (Jira)]

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

Jason Gustafson resolved KAFKA-13051.
-
Resolution: Fixed

> Require Principal Serde to be defined for 3.0
> -
>
> Key: KAFKA-13051
> URL: https://issues.apache.org/jira/browse/KAFKA-13051
> Project: Kafka
>  Issue Type: Task
>Reporter: Ryan Dielhenn
>Assignee: Ryan Dielhenn
>Priority: Blocker
> Fix For: 3.0.0
>
>
> As specified in 
> [KIP-590|https://cwiki.apache.org/confluence/display/KAFKA/KIP-590%3A+Redirect+Zookeeper+Mutation+Protocols+to+The+Controller]
>  KafkaPrincipalBuilder implementations must implement KafkaPrincipalSerde in 
> order to enable request forwarding between brokers.



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

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.0 #20

[Apache Jenkins Server]

See 

Re: Email contact for PMC regarding trademark questions/issues

[Matthias J. Sax]

You can reach out to priv...@kafka.apache.org to reach the PMC.

-Matthias

On 7/9/21 4:31 AM, Matthew de Detrich wrote:
> Hello everyone,
> 
> Does anyone know what the contact email is for Kafka PMC? I have a couple
> of questions regarding the Kafka trademark (i.e.
> https://www.apache.org/foundation/marks/faq/#poweredby and
> https://kafka.apache.org/trademark)
> 
> Regards
> 

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #312

[Apache Jenkins Server]

See 


Changes:


--
[...truncated 413985 lines...]
[2021-07-13T19:00:19.470Z] PlaintextConsumerTest > 
testPerPartitionLagMetricsCleanUpWithAssign() STARTED
[2021-07-13T19:00:25.273Z] 
[2021-07-13T19:00:25.273Z] PlaintextConsumerTest > 
testPerPartitionLagMetricsCleanUpWithAssign() PASSED
[2021-07-13T19:00:25.273Z] 
[2021-07-13T19:00:25.273Z] PlaintextConsumerTest > 
testPartitionsForInvalidTopic() STARTED
[2021-07-13T19:00:27.046Z] 
[2021-07-13T19:00:27.046Z] PlaintextConsumerTest > 
testPartitionsForInvalidTopic() PASSED
[2021-07-13T19:00:27.046Z] 
[2021-07-13T19:00:27.046Z] PlaintextConsumerTest > 
testPauseStateNotPreservedByRebalance() STARTED
[2021-07-13T19:00:34.118Z] 
[2021-07-13T19:00:34.118Z] PlaintextConsumerTest > 
testPauseStateNotPreservedByRebalance() PASSED
[2021-07-13T19:00:34.118Z] 
[2021-07-13T19:00:34.118Z] PlaintextConsumerTest > 
testFetchHonoursFetchSizeIfLargeRecordNotFirst() STARTED
[2021-07-13T19:00:39.920Z] 
[2021-07-13T19:00:39.920Z] PlaintextConsumerTest > 
testFetchHonoursFetchSizeIfLargeRecordNotFirst() PASSED
[2021-07-13T19:00:39.920Z] 
[2021-07-13T19:00:39.920Z] PlaintextConsumerTest > testSeek() STARTED
[2021-07-13T19:00:47.041Z] 
[2021-07-13T19:00:47.041Z] PlaintextConsumerTest > testSeek() PASSED
[2021-07-13T19:00:47.041Z] 
[2021-07-13T19:00:47.041Z] PlaintextConsumerTest > 
testConsumingWithNullGroupId() STARTED
[2021-07-13T19:00:55.703Z] 
[2021-07-13T19:00:55.703Z] PlaintextConsumerTest > 
testConsumingWithNullGroupId() PASSED
[2021-07-13T19:00:55.703Z] 
[2021-07-13T19:00:55.703Z] PlaintextConsumerTest > testPositionAndCommit() 
STARTED
[2021-07-13T19:01:01.585Z] 
[2021-07-13T19:01:01.585Z] PlaintextConsumerTest > testPositionAndCommit() 
PASSED
[2021-07-13T19:01:01.585Z] 
[2021-07-13T19:01:01.585Z] PlaintextConsumerTest > 
testFetchRecordLargerThanMaxPartitionFetchBytes() STARTED
[2021-07-13T19:01:06.585Z] 
[2021-07-13T19:01:06.585Z] PlaintextConsumerTest > 
testFetchRecordLargerThanMaxPartitionFetchBytes() PASSED
[2021-07-13T19:01:06.585Z] 
[2021-07-13T19:01:06.585Z] PlaintextConsumerTest > testUnsubscribeTopic() 
STARTED
[2021-07-13T19:01:12.431Z] 
[2021-07-13T19:01:12.431Z] PlaintextConsumerTest > testUnsubscribeTopic() PASSED
[2021-07-13T19:01:12.431Z] 
[2021-07-13T19:01:12.431Z] PlaintextConsumerTest > 
testMultiConsumerSessionTimeoutOnClose() STARTED
[2021-07-13T19:01:24.331Z] 
[2021-07-13T19:01:24.331Z] PlaintextConsumerTest > 
testMultiConsumerSessionTimeoutOnClose() PASSED
[2021-07-13T19:01:24.331Z] 
[2021-07-13T19:01:24.331Z] PlaintextConsumerTest > 
testMultiConsumerStickyAssignor() STARTED
[2021-07-13T19:01:40.710Z] 
[2021-07-13T19:01:40.710Z] PlaintextConsumerTest > 
testMultiConsumerStickyAssignor() PASSED
[2021-07-13T19:01:40.710Z] 
[2021-07-13T19:01:40.710Z] PlaintextConsumerTest > 
testFetchRecordLargerThanFetchMaxBytes() STARTED
[2021-07-13T19:01:46.512Z] 
[2021-07-13T19:01:46.512Z] PlaintextConsumerTest > 
testFetchRecordLargerThanFetchMaxBytes() PASSED
[2021-07-13T19:01:46.512Z] 
[2021-07-13T19:01:46.512Z] PlaintextConsumerTest > testAutoCommitOnClose() 
STARTED
[2021-07-13T19:01:52.314Z] 
[2021-07-13T19:01:52.314Z] PlaintextConsumerTest > testAutoCommitOnClose() 
PASSED
[2021-07-13T19:01:52.314Z] 
[2021-07-13T19:01:52.314Z] PlaintextConsumerTest > testListTopics() STARTED
[2021-07-13T19:01:55.927Z] 
[2021-07-13T19:01:55.927Z] PlaintextConsumerTest > testListTopics() PASSED
[2021-07-13T19:01:55.927Z] 
[2021-07-13T19:01:55.927Z] PlaintextConsumerTest > 
testExpandingTopicSubscriptions() STARTED
[2021-07-13T19:02:01.857Z] 
[2021-07-13T19:02:01.857Z] PlaintextConsumerTest > 
testExpandingTopicSubscriptions() PASSED
[2021-07-13T19:02:01.857Z] 
[2021-07-13T19:02:01.857Z] PlaintextConsumerTest > 
testMultiConsumerDefaultAssignor() STARTED
[2021-07-13T19:02:14.032Z] 
[2021-07-13T19:02:14.032Z] PlaintextConsumerTest > 
testMultiConsumerDefaultAssignor() PASSED
[2021-07-13T19:02:14.032Z] 
[2021-07-13T19:02:14.032Z] PlaintextConsumerTest > testInterceptors() STARTED
[2021-07-13T19:02:18.690Z] 
[2021-07-13T19:02:18.690Z] PlaintextConsumerTest > testInterceptors() PASSED
[2021-07-13T19:02:18.690Z] 
[2021-07-13T19:02:18.690Z] PlaintextConsumerTest > 
testConsumingWithEmptyGroupId() STARTED
[2021-07-13T19:02:24.507Z] 
[2021-07-13T19:02:24.507Z] PlaintextConsumerTest > 
testConsumingWithEmptyGroupId() PASSED
[2021-07-13T19:02:24.507Z] 
[2021-07-13T19:02:24.507Z] PlaintextConsumerTest > testPatternUnsubscription() 
STARTED
[2021-07-13T19:02:34.595Z] 
[2021-07-13T19:02:34.595Z] PlaintextConsumerTest > testPatternUnsubscription() 
PASSED
[2021-07-13T19:02:34.595Z] 
[2021-07-13T19:02:34.596Z] PlaintextConsumerTest > testGroupConsumption() 
STARTED
[2021-07-13T19:02:41.668Z] 
[2021-07-13T19:02:41.668Z] PlaintextConsumerTest > testGroupConsumption() PASSED
[2021-07-13T19:02:41.668Z] 
[2021-07-13T19:02:41.668Z] PlaintextConsumerTest > testPartitionsF

[jira] [Created] (KAFKA-13079) Forgotten Topics in Fetch Requests may incorrectly use topic IDs

[Justine Olshan (Jira)]

Justine Olshan created KAFKA-13079:
--

 Summary: Forgotten Topics in Fetch Requests may incorrectly use 
topic IDs
 Key: KAFKA-13079
 URL: https://issues.apache.org/jira/browse/KAFKA-13079
 Project: Kafka
  Issue Type: Bug
Affects Versions: 3.1.0
Reporter: Justine Olshan


In the new code for Fetch, we only check if the topics contained in the session 
have IDs to decide whether to send a version < 13 (topic names) or version 13+ 
(topic IDs) request. However, if we have an empty session that previously did 
not use IDs, we will try to send a request to forget the topics. Since all 
topics in the session (none) were not missing topic ids, we will send a version 
13 request. This request will have the Zero UUID and fail.

The result is that we close the session and mark any partitions in it as 
errored, but the message is confusing and the request is not correct. We should 
somehow also track forgotten topics when deciding what version to use.



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

[jira] [Resolved] (KAFKA-13075) Consolidate RocksDBStoreTest and RocksDBKeyValueStoreTest

[A. Sophie Blee-Goldman (Jira)]

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

A. Sophie Blee-Goldman resolved KAFKA-13075.

Fix Version/s: 3.1.0
   Resolution: Fixed

> Consolidate RocksDBStoreTest and RocksDBKeyValueStoreTest
> -
>
> Key: KAFKA-13075
> URL: https://issues.apache.org/jira/browse/KAFKA-13075
> Project: Kafka
>  Issue Type: Improvement
>  Components: streams
>Reporter: A. Sophie Blee-Goldman
>Assignee: Chun-Hao Tang
>Priority: Major
>  Labels: newbie, newbie++
> Fix For: 3.1.0
>
>
> Looks like we have two different test classes covering pretty much the same 
> thing: RocksDBStore. It seems like RocksDBKeyValueStoreTest was the original 
> test class for RocksDBStore, but someone later added RocksDBStoreTest, most 
> likely because they didn't notice the RocksDBKeyValueStoreTest which didn't 
> follow the usual naming scheme for test classes. 
> We should consolidate these two into a single file, ideally retaining the 
> RocksDBStoreTest name since that conforms to the test naming pattern used 
> throughout Streams (and so this same thing doesn't happen again). It should 
> also extend AbstractKeyValueStoreTest like the RocksDBKeyValueStoreTest 
> currently does so we continue to get the benefit of all the tests in there as 
> well



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

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.0 #21

[Apache Jenkins Server]

See 


Changes:


--
[...truncated 481217 lines...]
[2021-07-13T20:56:09.230Z] 
[2021-07-13T20:56:09.230Z] AuthorizerIntegrationTest > 
testListTransactionsAuthorization() PASSED
[2021-07-13T20:56:09.230Z] 
[2021-07-13T20:56:09.230Z] AuthorizerIntegrationTest > 
testOffsetFetchTopicDescribe() STARTED
[2021-07-13T20:56:11.773Z] 
[2021-07-13T20:56:11.773Z] AuthorizerIntegrationTest > 
testOffsetFetchTopicDescribe() PASSED
[2021-07-13T20:56:11.773Z] 
[2021-07-13T20:56:11.773Z] AuthorizerIntegrationTest > 
testCommitWithTopicAndGroupRead() STARTED
[2021-07-13T20:56:17.544Z] 
[2021-07-13T20:56:17.544Z] AuthorizerIntegrationTest > 
testCommitWithTopicAndGroupRead() PASSED
[2021-07-13T20:56:17.544Z] 
[2021-07-13T20:56:17.544Z] AuthorizerIntegrationTest > 
testOffsetFetchMultipleGroupsAuthorization() STARTED
[2021-07-13T20:56:23.440Z] 
[2021-07-13T20:56:23.440Z] AuthorizerIntegrationTest > 
testOffsetFetchMultipleGroupsAuthorization() PASSED
[2021-07-13T20:56:23.440Z] 
[2021-07-13T20:56:23.440Z] AuthorizerIntegrationTest > 
testIdempotentProducerNoIdempotentWriteAclInInitProducerId() STARTED
[2021-07-13T20:56:27.084Z] 
[2021-07-13T20:56:27.084Z] AuthorizerIntegrationTest > 
testIdempotentProducerNoIdempotentWriteAclInInitProducerId() PASSED
[2021-07-13T20:56:27.084Z] 
[2021-07-13T20:56:27.084Z] AuthorizerIntegrationTest > 
testSimpleConsumeWithExplicitSeekAndNoGroupAccess() STARTED
[2021-07-13T20:56:30.489Z] 
[2021-07-13T20:56:30.489Z] AuthorizerIntegrationTest > 
testSimpleConsumeWithExplicitSeekAndNoGroupAccess() PASSED
[2021-07-13T20:56:30.489Z] 
[2021-07-13T20:56:30.489Z] SslProducerSendTest > 
testSendNonCompressedMessageWithCreateTime() STARTED
[2021-07-13T20:56:36.206Z] 
[2021-07-13T20:56:36.206Z] SslProducerSendTest > 
testSendNonCompressedMessageWithCreateTime() PASSED
[2021-07-13T20:56:36.206Z] 
[2021-07-13T20:56:36.206Z] SslProducerSendTest > testClose() STARTED
[2021-07-13T20:56:43.095Z] 
[2021-07-13T20:56:43.095Z] SslProducerSendTest > testClose() PASSED
[2021-07-13T20:56:43.095Z] 
[2021-07-13T20:56:43.095Z] SslProducerSendTest > testFlush() STARTED
[2021-07-13T20:56:50.063Z] 
[2021-07-13T20:56:50.063Z] SslProducerSendTest > testFlush() PASSED
[2021-07-13T20:56:50.063Z] 
[2021-07-13T20:56:50.063Z] SslProducerSendTest > testSendToPartition() STARTED
[2021-07-13T20:56:55.535Z] 
[2021-07-13T20:56:55.535Z] SslProducerSendTest > testSendToPartition() PASSED
[2021-07-13T20:56:55.535Z] 
[2021-07-13T20:56:55.535Z] SslProducerSendTest > testSendOffset() STARTED
[2021-07-13T20:57:01.266Z] 
[2021-07-13T20:57:01.266Z] SslProducerSendTest > testSendOffset() PASSED
[2021-07-13T20:57:01.266Z] 
[2021-07-13T20:57:01.266Z] SslProducerSendTest > 
testSendCompressedMessageWithCreateTime() STARTED
[2021-07-13T20:57:06.599Z] 
[2021-07-13T20:57:06.599Z] SslProducerSendTest > 
testSendCompressedMessageWithCreateTime() PASSED
[2021-07-13T20:57:06.599Z] 
[2021-07-13T20:57:06.599Z] SslProducerSendTest > 
testCloseWithZeroTimeoutFromCallerThread() STARTED
[2021-07-13T20:57:29.276Z] 
[2021-07-13T20:57:29.276Z] SslProducerSendTest > 
testCloseWithZeroTimeoutFromCallerThread() PASSED
[2021-07-13T20:57:29.276Z] 
[2021-07-13T20:57:29.276Z] SslProducerSendTest > 
testCloseWithZeroTimeoutFromSenderThread() STARTED
[2021-07-13T20:57:50.121Z] 
[2021-07-13T20:57:50.121Z] SslProducerSendTest > 
testCloseWithZeroTimeoutFromSenderThread() PASSED
[2021-07-13T20:57:50.121Z] 
[2021-07-13T20:57:50.121Z] SslProducerSendTest > 
testSendBeforeAndAfterPartitionExpansion() STARTED
[2021-07-13T20:58:00.549Z] 
[2021-07-13T20:58:00.549Z] SslProducerSendTest > 
testSendBeforeAndAfterPartitionExpansion() PASSED
[2021-07-13T20:58:00.549Z] 
[2021-07-13T20:58:00.549Z] ProducerCompressionTest > testCompression(String) > 
kafka.api.test.ProducerCompressionTest.testCompression(String)[1] STARTED
[2021-07-13T20:58:04.937Z] 
[2021-07-13T20:58:04.937Z] ProducerCompressionTest > testCompression(String) > 
kafka.api.test.ProducerCompressionTest.testCompression(String)[1] PASSED
[2021-07-13T20:58:04.937Z] 
[2021-07-13T20:58:04.937Z] ProducerCompressionTest > testCompression(String) > 
kafka.api.test.ProducerCompressionTest.testCompression(String)[2] STARTED
[2021-07-13T20:58:10.620Z] 
[2021-07-13T20:58:10.620Z] ProducerCompressionTest > testCompression(String) > 
kafka.api.test.ProducerCompressionTest.testCompression(String)[2] PASSED
[2021-07-13T20:58:10.620Z] 
[2021-07-13T20:58:10.620Z] ProducerCompressionTest > testCompression(String) > 
kafka.api.test.ProducerCompressionTest.testCompression(String)[3] STARTED
[2021-07-13T20:58:15.065Z] 
[2021-07-13T20:58:15.065Z] ProducerCompressionTest > testCompression(String) > 
kafka.api.test.ProducerCompressionTest.testCompression(String)[3] PASSED
[2021-07-13T20:58:15.065Z] 
[2021-07-13T20:58:15.065Z] ProducerCompressionTest > testCompression(String) > 
kafka.api.test.ProducerCompressionTest.testCompression(

[jira] [Created] (KAFKA-13080) Fetch snapshot request are not directed to kraft in controller

[Jose Armando Garcia Sancio (Jira)]

Jose Armando Garcia Sancio created KAFKA-13080:
--

 Summary: Fetch snapshot request are not directed to kraft in 
controller
 Key: KAFKA-13080
 URL: https://issues.apache.org/jira/browse/KAFKA-13080
 Project: Kafka
  Issue Type: Bug
  Components: controller, kraft
Reporter: Jose Armando Garcia Sancio
Assignee: Jose Armando Garcia Sancio
 Fix For: 3.0.0


Kraft followers and observer are seeing the following error
{code:java}
[2021-07-13 18:15:47,289] ERROR [RaftManager nodeId=2] Unexpected error 
UNKNOWN_SERVER_ERROR in FETCH_SNAPSHOT response: 
InboundResponse(correlationId=29862, 
data=FetchSnapshotResponseData(throttleTimeMs=0, errorCode=-1, topics=[]), 
sourceId=3001) (org.apache.kafka.raft.KafkaRaftClient) {code}
This is because ControllerApis is not directing FetchSnapshost request to the 
raft manager.



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

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 2.8 #46

[Apache Jenkins Server]

See 

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #313

[Apache Jenkins Server]

See 

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 2.8 #47

[Apache Jenkins Server]

See 

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.0 #22

[Apache Jenkins Server]

See 

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #314

[Apache Jenkins Server]

See 


Changes:


--
[...truncated 412399 lines...]
[2021-07-13T23:53:37.166Z] [INFO] Parameter: packageInPathFormat, Value: myapps
[2021-07-13T23:53:37.166Z] [INFO] Parameter: package, Value: myapps
[2021-07-13T23:53:37.166Z] [INFO] Parameter: version, Value: 0.1
[2021-07-13T23:53:37.166Z] [INFO] Parameter: groupId, Value: streams.examples
[2021-07-13T23:53:37.166Z] [INFO] Parameter: artifactId, Value: streams.examples
[2021-07-13T23:53:37.166Z] [INFO] Project created from Archetype in dir: 
/home/jenkins/workspace/Kafka_kafka_trunk/streams/quickstart/test-streams-archetype/streams.examples
[2021-07-13T23:53:37.166Z] [INFO] 

[2021-07-13T23:53:37.166Z] [INFO] BUILD SUCCESS
[2021-07-13T23:53:37.166Z] [INFO] 

[2021-07-13T23:53:37.166Z] [INFO] Total time:  2.309 s
[2021-07-13T23:53:37.166Z] [INFO] Finished at: 2021-07-13T23:53:36Z
[2021-07-13T23:53:37.167Z] [INFO] 

[Pipeline] dir
[2021-07-13T23:53:37.168Z] Running in 
/home/jenkins/workspace/Kafka_kafka_trunk/streams/quickstart/test-streams-archetype/streams.examples
[Pipeline] {
[Pipeline] sh
[2021-07-13T23:53:38.918Z] 
[2021-07-13T23:53:38.918Z] ControllerIntegrationTest > testIdempotentAlterIsr() 
PASSED
[2021-07-13T23:53:38.918Z] 
[2021-07-13T23:53:38.918Z] ControllerIntegrationTest > 
testLeaderAndIsrWhenEntireIsrOfflineAndUncleanLeaderElectionEnabled() STARTED
[2021-07-13T23:53:39.308Z] + mvn compile
[2021-07-13T23:53:40.243Z] [INFO] Scanning for projects...
[2021-07-13T23:53:40.243Z] [INFO] 
[2021-07-13T23:53:40.243Z] [INFO] -< 
streams.examples:streams.examples >--
[2021-07-13T23:53:40.243Z] [INFO] Building Kafka Streams Quickstart :: Java 0.1
[2021-07-13T23:53:40.243Z] [INFO] [ jar 
]-
[2021-07-13T23:53:41.177Z] [INFO] 
[2021-07-13T23:53:41.177Z] [INFO] --- maven-resources-plugin:2.6:resources 
(default-resources) @ streams.examples ---
[2021-07-13T23:53:41.177Z] [INFO] Using 'UTF-8' encoding to copy filtered 
resources.
[2021-07-13T23:53:41.177Z] [INFO] Copying 1 resource
[2021-07-13T23:53:41.177Z] [INFO] 
[2021-07-13T23:53:41.177Z] [INFO] --- maven-compiler-plugin:3.1:compile 
(default-compile) @ streams.examples ---
[2021-07-13T23:53:41.177Z] [INFO] Changes detected - recompiling the module!
[2021-07-13T23:53:41.177Z] [INFO] Compiling 3 source files to 
/home/jenkins/workspace/Kafka_kafka_trunk/streams/quickstart/test-streams-archetype/streams.examples/target/classes
[2021-07-13T23:53:42.926Z] [INFO] 

[2021-07-13T23:53:42.926Z] [INFO] BUILD SUCCESS
[2021-07-13T23:53:42.926Z] [INFO] 

[2021-07-13T23:53:42.926Z] [INFO] Total time:  2.376 s
[2021-07-13T23:53:42.926Z] [INFO] Finished at: 2021-07-13T23:53:41Z
[2021-07-13T23:53:42.926Z] [INFO] 

[Pipeline] }
[Pipeline] // dir
[Pipeline] }
[Pipeline] // dir
[Pipeline] }
[Pipeline] // dir
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // withEnv
[Pipeline] }
[Pipeline] // node
[Pipeline] }
[Pipeline] // timestamps
[Pipeline] }
[Pipeline] // timeout
[Pipeline] }
[Pipeline] // stage
[Pipeline] }
[2021-07-13T23:53:43.752Z] 
[2021-07-13T23:53:43.752Z] ControllerIntegrationTest > 
testLeaderAndIsrWhenEntireIsrOfflineAndUncleanLeaderElectionEnabled() PASSED
[2021-07-13T23:53:43.752Z] 
[2021-07-13T23:53:43.752Z] ControllerIntegrationTest > 
testControllerMoveOnPartitionReassignment() STARTED
[2021-07-13T23:53:46.983Z] 
[2021-07-13T23:53:46.983Z] ControllerIntegrationTest > 
testControllerMoveOnPartitionReassignment() PASSED
[2021-07-13T23:53:46.983Z] 
[2021-07-13T23:53:46.983Z] ControllerIntegrationTest > 
testControllerFeatureZNodeSetupWhenFeatureVersioningIsEnabledWithEnabledExistingFeatureZNode()
 STARTED
[2021-07-13T23:53:52.488Z] 
[2021-07-13T23:53:52.488Z] ControllerIntegrationTest > 
testControllerFeatureZNodeSetupWhenFeatureVersioningIsEnabledWithEnabledExistingFeatureZNode()
 PASSED
[2021-07-13T23:53:52.488Z] 
[2021-07-13T23:53:52.488Z] ControllerIntegrationTest > 
testControllerMoveOnTopicCreation() STARTED
[2021-07-13T23:53:56.697Z] 
[2021-07-13T23:53:56.697Z] ControllerIntegrationTest > 
testControllerMoveOnTopicCreation() PASSED
[2021-07-13T23:53:56.697Z] 
[2021-07-13T23:53:56.697Z] ControllerIntegrationTest > 
testControllerFeatureZNodeSetupWhenFeatureVersioningIsDisabledWithDisabledExistingFeatureZNode()
 STARTED
[2021-07-13T23:53:58.793Z] 
[2021-07-13T23:53:58.793Z] ControllerIntegrationTest > 
testControllerF

[jira] [Resolved] (KAFKA-12554) Split Log layer into Log and LocalLog

[Jun Rao (Jira)]

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

Jun Rao resolved KAFKA-12554.
-
Fix Version/s: 3.1.0
   Resolution: Fixed

merged the PR to trunk.

> Split Log layer into Log and LocalLog
> -
>
> Key: KAFKA-12554
> URL: https://issues.apache.org/jira/browse/KAFKA-12554
> Project: Kafka
>  Issue Type: Sub-task
>Reporter: Kowshik Prakasam
>Assignee: Kowshik Prakasam
>Priority: Major
> Fix For: 3.1.0
>
>
> Split Log layer into Log and LocalLog based on the proposal described in this 
> document: 
> [https://docs.google.com/document/d/1dQJL4MCwqQJSPmZkVmVzshFZKuFy_bCPtubav4wBfHQ/edit#].



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

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.0 #23

[Apache Jenkins Server]

See 


Changes:


--
[...truncated 211482 lines...]
[2021-07-14T01:32:34.220Z] 
[2021-07-14T01:32:34.220Z] DeleteOffsetsConsumerGroupCommandIntegrationTest > 
testDeleteOffsetsOfEmptyConsumerGroupWithTopicPartition() PASSED
[2021-07-14T01:32:34.220Z] 
[2021-07-14T01:32:34.220Z] DeleteOffsetsConsumerGroupCommandIntegrationTest > 
testDeleteOffsetsOfEmptyConsumerGroupWithTopicOnly() STARTED
[2021-07-14T01:32:36.884Z] 
[2021-07-14T01:32:36.884Z] DeleteOffsetsConsumerGroupCommandIntegrationTest > 
testDeleteOffsetsOfEmptyConsumerGroupWithTopicOnly() PASSED
[2021-07-14T01:32:36.884Z] 
[2021-07-14T01:32:36.884Z] DeleteOffsetsConsumerGroupCommandIntegrationTest > 
testDeleteOffsetsOfStableConsumerGroupWithTopicPartition() STARTED
[2021-07-14T01:32:40.627Z] 
[2021-07-14T01:32:40.627Z] DeleteOffsetsConsumerGroupCommandIntegrationTest > 
testDeleteOffsetsOfStableConsumerGroupWithTopicPartition() PASSED
[2021-07-14T01:32:40.627Z] 
[2021-07-14T01:32:40.627Z] DeleteOffsetsConsumerGroupCommandIntegrationTest > 
testDeleteOffsetsNonExistingGroup() STARTED
[2021-07-14T01:32:42.377Z] 
[2021-07-14T01:32:42.377Z] DeleteOffsetsConsumerGroupCommandIntegrationTest > 
testDeleteOffsetsNonExistingGroup() PASSED
[2021-07-14T01:32:42.377Z] 
[2021-07-14T01:32:42.377Z] DeleteOffsetsConsumerGroupCommandIntegrationTest > 
testDeleteOffsetsOfStableConsumerGroupWithUnknownTopicOnly() STARTED
[2021-07-14T01:32:50.787Z] 
[2021-07-14T01:32:50.787Z] DeleteOffsetsConsumerGroupCommandIntegrationTest > 
testDeleteOffsetsOfStableConsumerGroupWithUnknownTopicOnly() PASSED
[2021-07-14T01:32:50.787Z] 
[2021-07-14T01:32:50.787Z] TopicCommandIntegrationTest > 
testAlterPartitionCount() STARTED
[2021-07-14T01:32:55.559Z] 
[2021-07-14T01:32:55.559Z] TopicCommandIntegrationTest > 
testAlterPartitionCount() PASSED
[2021-07-14T01:32:55.559Z] 
[2021-07-14T01:32:55.559Z] TopicCommandIntegrationTest > 
testCreatePartitionsDoesNotRetryThrottlingQuotaExceededException() STARTED
[2021-07-14T01:32:59.300Z] 
[2021-07-14T01:32:59.300Z] TopicCommandIntegrationTest > 
testCreatePartitionsDoesNotRetryThrottlingQuotaExceededException() PASSED
[2021-07-14T01:32:59.300Z] 
[2021-07-14T01:32:59.300Z] TopicCommandIntegrationTest > 
testAlterWhenTopicDoesntExistWithIfExists() STARTED
[2021-07-14T01:33:03.043Z] 
[2021-07-14T01:33:03.043Z] TopicCommandIntegrationTest > 
testAlterWhenTopicDoesntExistWithIfExists() PASSED
[2021-07-14T01:33:03.043Z] 
[2021-07-14T01:33:03.043Z] TopicCommandIntegrationTest > 
testCreateWithDefaultReplication() STARTED
[2021-07-14T01:33:06.618Z] 
[2021-07-14T01:33:06.618Z] TopicCommandIntegrationTest > 
testCreateWithDefaultReplication() PASSED
[2021-07-14T01:33:06.618Z] 
[2021-07-14T01:33:06.618Z] TopicCommandIntegrationTest > 
testDescribeAtMinIsrPartitions() STARTED
[2021-07-14T01:33:16.790Z] 
[2021-07-14T01:33:16.790Z] TopicCommandIntegrationTest > 
testDescribeAtMinIsrPartitions() PASSED
[2021-07-14T01:33:16.790Z] 
[2021-07-14T01:33:16.790Z] TopicCommandIntegrationTest > 
testCreateWithNegativeReplicationFactor() STARTED
[2021-07-14T01:33:19.417Z] 
[2021-07-14T01:33:19.417Z] TopicCommandIntegrationTest > 
testCreateWithNegativeReplicationFactor() PASSED
[2021-07-14T01:33:19.417Z] 
[2021-07-14T01:33:19.417Z] TopicCommandIntegrationTest > 
testCreateWithInvalidReplicationFactor() STARTED
[2021-07-14T01:33:23.449Z] 
[2021-07-14T01:33:23.449Z] TopicCommandIntegrationTest > 
testCreateWithInvalidReplicationFactor() PASSED
[2021-07-14T01:33:23.449Z] 
[2021-07-14T01:33:23.449Z] TopicCommandIntegrationTest > 
testDeleteTopicDoesNotRetryThrottlingQuotaExceededException() STARTED
[2021-07-14T01:33:28.137Z] 
[2021-07-14T01:33:28.137Z] TopicCommandIntegrationTest > 
testDeleteTopicDoesNotRetryThrottlingQuotaExceededException() PASSED
[2021-07-14T01:33:28.137Z] 
[2021-07-14T01:33:28.137Z] TopicCommandIntegrationTest > 
testListTopicsWithExcludeInternal() STARTED
[2021-07-14T01:33:32.042Z] 
[2021-07-14T01:33:32.042Z] TopicCommandIntegrationTest > 
testListTopicsWithExcludeInternal() PASSED
[2021-07-14T01:33:32.042Z] 
[2021-07-14T01:33:32.042Z] TopicCommandIntegrationTest > 
testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress() STARTED
[2021-07-14T01:33:37.847Z] 
[2021-07-14T01:33:37.847Z] TopicCommandIntegrationTest > 
testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress() PASSED
[2021-07-14T01:33:37.847Z] 
[2021-07-14T01:33:37.847Z] TopicCommandIntegrationTest > 
testCreateWithNegativePartitionCount() STARTED
[2021-07-14T01:33:41.421Z] 
[2021-07-14T01:33:41.421Z] TopicCommandIntegrationTest > 
testCreateWithNegativePartitionCount() PASSED
[2021-07-14T01:33:41.421Z] 
[2021-07-14T01:33:41.421Z] TopicCommandIntegrationTest > 
testAlterWhenTopicDoesntExist() STARTED
[2021-07-14T01:33:44.997Z] 
[2021-07-14T01:33:44.997Z] TopicCommandIntegrationTest > 
testAlterWhenTopicDoesntExist() PASSED
[2021-07-14T01:33:44.997Z] 
[

[jira] [Created] (KAFKA-13081) Port sticky assignor fixes (KAFKA-12984) back to 2.8

[A. Sophie Blee-Goldman (Jira)]

A. Sophie Blee-Goldman created KAFKA-13081:
--

 Summary: Port sticky assignor fixes (KAFKA-12984) back to 2.8
 Key: KAFKA-13081
 URL: https://issues.apache.org/jira/browse/KAFKA-13081
 Project: Kafka
  Issue Type: Bug
Reporter: A. Sophie Blee-Goldman
 Fix For: 2.8.1


We should make sure that fix #1 and #2 of 
[#10985|https://github.com/apache/kafka/pull/10985] make it back to the 2.8 
sticky assignor, since it's pretty much impossible to smoothly cherrypick that 
commit from 3.0 to 2.8 due to all the recent improvements and refactoring in 
the AbstractStickyAssignor. Either we can just extract and apply those two 
fixes to 2.8 directly, or go back and port all the commits that made this 
cherrypick difficult over to 2.8 as well. If we do so then cherrypicking the 
original commit should be easy



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

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #315

[Apache Jenkins Server]

See 


Changes:


--
[...truncated 212150 lines...]
[2021-07-14T01:57:43.842Z] > Task :raft:testClasses UP-TO-DATE
[2021-07-14T01:57:43.842Z] > Task :connect:json:testJar
[2021-07-14T01:57:43.842Z] > Task :connect:json:testSrcJar
[2021-07-14T01:57:43.842Z] > Task :metadata:compileTestJava UP-TO-DATE
[2021-07-14T01:57:43.842Z] > Task :metadata:testClasses UP-TO-DATE
[2021-07-14T01:57:43.842Z] > Task 
:clients:generateMetadataFileForMavenJavaPublication
[2021-07-14T01:57:43.842Z] > Task 
:clients:generatePomFileForMavenJavaPublication
[2021-07-14T01:57:43.842Z] 
[2021-07-14T01:57:43.842Z] > Task :streams:processMessages
[2021-07-14T01:57:43.842Z] Execution optimizations have been disabled for task 
':streams:processMessages' to ensure correctness due to the following reasons:
[2021-07-14T01:57:43.842Z]   - Gradle detected a problem with the following 
location: 
'/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk/streams/src/generated/java/org/apache/kafka/streams/internals/generated'.
 Reason: Task ':streams:srcJar' uses this output of task 
':streams:processMessages' without declaring an explicit or implicit 
dependency. This can lead to incorrect results being produced, depending on 
what order the tasks are executed. Please refer to 
https://docs.gradle.org/7.1.1/userguide/validation_problems.html#implicit_dependency
 for more details about this problem.
[2021-07-14T01:57:43.842Z] MessageGenerator: processed 1 Kafka message JSON 
files(s).
[2021-07-14T01:57:43.842Z] 
[2021-07-14T01:57:43.843Z] > Task :core:compileScala UP-TO-DATE
[2021-07-14T01:57:43.843Z] > Task :core:classes UP-TO-DATE
[2021-07-14T01:57:43.843Z] > Task :core:compileTestJava NO-SOURCE
[2021-07-14T01:57:43.843Z] > Task :streams:compileJava UP-TO-DATE
[2021-07-14T01:57:43.843Z] > Task :streams:classes UP-TO-DATE
[2021-07-14T01:57:43.843Z] > Task :streams:copyDependantLibs UP-TO-DATE
[2021-07-14T01:57:43.843Z] > Task :streams:jar UP-TO-DATE
[2021-07-14T01:57:43.843Z] > Task :streams:test-utils:compileJava UP-TO-DATE
[2021-07-14T01:57:44.772Z] > Task :core:compileTestScala UP-TO-DATE
[2021-07-14T01:57:44.772Z] > Task :core:testClasses UP-TO-DATE
[2021-07-14T01:57:44.772Z] > Task 
:streams:generateMetadataFileForMavenJavaPublication
[2021-07-14T01:57:48.329Z] > Task :connect:api:javadoc
[2021-07-14T01:57:48.329Z] > Task :connect:api:copyDependantLibs UP-TO-DATE
[2021-07-14T01:57:48.329Z] > Task :connect:api:jar UP-TO-DATE
[2021-07-14T01:57:48.329Z] > Task 
:connect:api:generateMetadataFileForMavenJavaPublication
[2021-07-14T01:57:48.329Z] > Task :connect:json:copyDependantLibs UP-TO-DATE
[2021-07-14T01:57:48.329Z] > Task :connect:json:jar UP-TO-DATE
[2021-07-14T01:57:48.329Z] > Task 
:connect:json:generateMetadataFileForMavenJavaPublication
[2021-07-14T01:57:48.329Z] > Task :connect:api:javadocJar
[2021-07-14T01:57:48.329Z] > Task 
:connect:json:publishMavenJavaPublicationToMavenLocal
[2021-07-14T01:57:48.329Z] > Task :connect:json:publishToMavenLocal
[2021-07-14T01:57:48.329Z] > Task :connect:api:compileTestJava UP-TO-DATE
[2021-07-14T01:57:48.329Z] > Task :connect:api:testClasses UP-TO-DATE
[2021-07-14T01:57:48.329Z] > Task :connect:api:testJar
[2021-07-14T01:57:48.329Z] > Task :connect:api:testSrcJar
[2021-07-14T01:57:48.329Z] > Task 
:connect:api:publishMavenJavaPublicationToMavenLocal
[2021-07-14T01:57:48.329Z] > Task :connect:api:publishToMavenLocal
[2021-07-14T01:57:52.058Z] > Task :streams:javadoc
[2021-07-14T01:57:52.990Z] > Task :streams:javadocJar
[2021-07-14T01:57:52.990Z] > Task :streams:compileTestJava UP-TO-DATE
[2021-07-14T01:57:52.990Z] > Task :streams:testClasses UP-TO-DATE
[2021-07-14T01:57:53.920Z] > Task :streams:testJar
[2021-07-14T01:57:53.920Z] > Task :streams:testSrcJar
[2021-07-14T01:57:53.920Z] > Task 
:streams:publishMavenJavaPublicationToMavenLocal
[2021-07-14T01:57:53.920Z] > Task :streams:publishToMavenLocal
[2021-07-14T01:57:54.850Z] > Task :clients:javadoc
[2021-07-14T01:57:54.850Z] > Task :clients:javadocJar
[2021-07-14T01:57:55.779Z] 
[2021-07-14T01:57:55.779Z] > Task :clients:srcJar
[2021-07-14T01:57:55.779Z] Execution optimizations have been disabled for task 
':clients:srcJar' to ensure correctness due to the following reasons:
[2021-07-14T01:57:55.779Z]   - Gradle detected a problem with the following 
location: 
'/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk/clients/src/generated/java'.
 Reason: Task ':clients:srcJar' uses this output of task 
':clients:processMessages' without declaring an explicit or implicit 
dependency. This can lead to incorrect results being produced, depending on 
what order the tasks are executed. Please refer to 
https://docs.gradle.org/7.1.1/userguide/validation_problems.html#implicit_dependency
 for more details about this problem.
[2021-07-14T01:57:57.522Z] 
[2021-07-14T01:57:57.522Z] > Task :clients:testJar
[2021-07-14T01:57:58.452Z] > Tas

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.0 #24

[Apache Jenkins Server]

See 


Changes:


--
[...truncated 211600 lines...]
[2021-07-14T03:48:46.138Z] > Task :raft:testClasses UP-TO-DATE
[2021-07-14T03:48:46.138Z] > Task :connect:json:testJar
[2021-07-14T03:48:46.138Z] > Task :connect:json:testSrcJar
[2021-07-14T03:48:46.138Z] > Task :metadata:compileTestJava UP-TO-DATE
[2021-07-14T03:48:46.138Z] > Task :metadata:testClasses UP-TO-DATE
[2021-07-14T03:48:46.138Z] > Task 
:clients:generateMetadataFileForMavenJavaPublication
[2021-07-14T03:48:46.138Z] > Task 
:clients:generatePomFileForMavenJavaPublication
[2021-07-14T03:48:46.138Z] 
[2021-07-14T03:48:46.138Z] > Task :streams:processMessages
[2021-07-14T03:48:46.138Z] Execution optimizations have been disabled for task 
':streams:processMessages' to ensure correctness due to the following reasons:
[2021-07-14T03:48:46.138Z]   - Gradle detected a problem with the following 
location: 
'/home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.0/streams/src/generated/java/org/apache/kafka/streams/internals/generated'.
 Reason: Task ':streams:srcJar' uses this output of task 
':streams:processMessages' without declaring an explicit or implicit 
dependency. This can lead to incorrect results being produced, depending on 
what order the tasks are executed. Please refer to 
https://docs.gradle.org/7.1.1/userguide/validation_problems.html#implicit_dependency
 for more details about this problem.
[2021-07-14T03:48:46.138Z] MessageGenerator: processed 1 Kafka message JSON 
files(s).
[2021-07-14T03:48:46.138Z] 
[2021-07-14T03:48:46.138Z] > Task :core:compileScala UP-TO-DATE
[2021-07-14T03:48:46.138Z] > Task :core:classes UP-TO-DATE
[2021-07-14T03:48:46.138Z] > Task :core:compileTestJava NO-SOURCE
[2021-07-14T03:48:46.138Z] > Task :streams:compileJava UP-TO-DATE
[2021-07-14T03:48:46.138Z] > Task :streams:classes UP-TO-DATE
[2021-07-14T03:48:46.138Z] > Task :streams:copyDependantLibs UP-TO-DATE
[2021-07-14T03:48:46.138Z] > Task :streams:jar UP-TO-DATE
[2021-07-14T03:48:46.138Z] > Task :streams:test-utils:compileJava UP-TO-DATE
[2021-07-14T03:48:46.138Z] > Task 
:streams:generateMetadataFileForMavenJavaPublication
[2021-07-14T03:48:47.076Z] > Task :core:compileTestScala UP-TO-DATE
[2021-07-14T03:48:47.076Z] > Task :core:testClasses UP-TO-DATE
[2021-07-14T03:48:50.014Z] > Task :connect:api:javadoc
[2021-07-14T03:48:50.014Z] > Task :connect:api:copyDependantLibs UP-TO-DATE
[2021-07-14T03:48:50.014Z] > Task :connect:api:jar UP-TO-DATE
[2021-07-14T03:48:50.014Z] > Task 
:connect:api:generateMetadataFileForMavenJavaPublication
[2021-07-14T03:48:50.014Z] > Task :connect:json:copyDependantLibs UP-TO-DATE
[2021-07-14T03:48:50.014Z] > Task :connect:json:jar UP-TO-DATE
[2021-07-14T03:48:50.014Z] > Task 
:connect:json:generateMetadataFileForMavenJavaPublication
[2021-07-14T03:48:50.014Z] > Task 
:connect:json:publishMavenJavaPublicationToMavenLocal
[2021-07-14T03:48:50.014Z] > Task :connect:json:publishToMavenLocal
[2021-07-14T03:48:50.014Z] > Task :connect:api:javadocJar
[2021-07-14T03:48:50.014Z] > Task :connect:api:compileTestJava UP-TO-DATE
[2021-07-14T03:48:50.014Z] > Task :connect:api:testClasses UP-TO-DATE
[2021-07-14T03:48:50.014Z] > Task :connect:api:testJar
[2021-07-14T03:48:50.014Z] > Task :connect:api:testSrcJar
[2021-07-14T03:48:50.014Z] > Task 
:connect:api:publishMavenJavaPublicationToMavenLocal
[2021-07-14T03:48:50.014Z] > Task :connect:api:publishToMavenLocal
[2021-07-14T03:48:52.647Z] > Task :streams:javadoc
[2021-07-14T03:48:52.647Z] > Task :streams:javadocJar
[2021-07-14T03:48:52.647Z] > Task :streams:compileTestJava UP-TO-DATE
[2021-07-14T03:48:52.647Z] > Task :streams:testClasses UP-TO-DATE
[2021-07-14T03:48:53.671Z] > Task :streams:testJar
[2021-07-14T03:48:53.671Z] > Task :streams:testSrcJar
[2021-07-14T03:48:53.671Z] > Task 
:streams:publishMavenJavaPublicationToMavenLocal
[2021-07-14T03:48:53.671Z] > Task :streams:publishToMavenLocal
[2021-07-14T03:48:55.718Z] > Task :clients:javadoc
[2021-07-14T03:48:55.718Z] > Task :clients:javadocJar
[2021-07-14T03:48:56.741Z] 
[2021-07-14T03:48:56.741Z] > Task :clients:srcJar
[2021-07-14T03:48:56.741Z] Execution optimizations have been disabled for task 
':clients:srcJar' to ensure correctness due to the following reasons:
[2021-07-14T03:48:56.741Z]   - Gradle detected a problem with the following 
location: 
'/home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.0/clients/src/generated/java'.
 Reason: Task ':clients:srcJar' uses this output of task 
':clients:processMessages' without declaring an explicit or implicit 
dependency. This can lead to incorrect results being produced, depending on 
what order the tasks are executed. Please refer to 
https://docs.gradle.org/7.1.1/userguide/validation_problems.html#implicit_dependency
 for more details about this problem.
[2021-07-14T03:48:56.741Z] 
[2021-07-14T03:48:56.741Z] > Task :clients:testJar
[2021-07-14T03:48:57.764Z] > Task :clie

[jira] [Created] (KAFKA-13082) Replace EasyMock for ProcessorContextTest

[Chun-Hao Tang (Jira)]

Chun-Hao Tang created KAFKA-13082:
-

 Summary: Replace EasyMock for ProcessorContextTest
 Key: KAFKA-13082
 URL: https://issues.apache.org/jira/browse/KAFKA-13082
 Project: Kafka
  Issue Type: Sub-task
Reporter: Chun-Hao Tang
Assignee: Chun-Hao Tang






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

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #316

[Apache Jenkins Server]

See 


Changes:


--
[...truncated 212574 lines...]
[2021-07-14T04:13:25.743Z] ControllerIntegrationTest > 
testPartitionReassignmentToBrokerWithOfflineLogDir() STARTED
[2021-07-14T04:13:29.826Z] 
[2021-07-14T04:13:29.826Z] ControllerIntegrationTest > 
testPartitionReassignmentToBrokerWithOfflineLogDir() PASSED
[2021-07-14T04:13:29.826Z] 
[2021-07-14T04:13:29.826Z] ControllerIntegrationTest > 
testPreferredReplicaLeaderElectionWithOfflinePreferredReplica() STARTED
[2021-07-14T04:13:34.109Z] 
[2021-07-14T04:13:34.109Z] ControllerIntegrationTest > 
testPreferredReplicaLeaderElectionWithOfflinePreferredReplica() PASSED
[2021-07-14T04:13:34.109Z] 
[2021-07-14T04:13:34.109Z] ControllerIntegrationTest > 
testMetadataPropagationOnControlPlane() STARTED
[2021-07-14T04:13:36.207Z] 
[2021-07-14T04:13:36.207Z] ControllerIntegrationTest > 
testMetadataPropagationOnControlPlane() PASSED
[2021-07-14T04:13:36.207Z] 
[2021-07-14T04:13:36.207Z] ControllerIntegrationTest > 
testControllerFeatureZNodeSetupWhenFeatureVersioningIsEnabledWithNonExistingFeatureZNode()
 STARTED
[2021-07-14T04:13:38.308Z] 
[2021-07-14T04:13:38.308Z] ControllerIntegrationTest > 
testControllerFeatureZNodeSetupWhenFeatureVersioningIsEnabledWithNonExistingFeatureZNode()
 PASSED
[2021-07-14T04:13:38.308Z] 
[2021-07-14T04:13:38.308Z] ControllerIntegrationTest > testAlterIsrErrors() 
STARTED
[2021-07-14T04:13:40.576Z] 
[2021-07-14T04:13:40.576Z] ControllerIntegrationTest > testAlterIsrErrors() 
PASSED
[2021-07-14T04:13:40.576Z] 
[2021-07-14T04:13:40.576Z] ControllerIntegrationTest > 
testAutoPreferredReplicaLeaderElection() STARTED
[2021-07-14T04:13:49.143Z] 
[2021-07-14T04:13:49.143Z] ControllerIntegrationTest > 
testAutoPreferredReplicaLeaderElection() PASSED
[2021-07-14T04:13:49.143Z] 
[2021-07-14T04:13:49.143Z] ControllerIntegrationTest > testTopicCreation() 
STARTED
[2021-07-14T04:13:52.216Z] 
[2021-07-14T04:13:52.216Z] ControllerIntegrationTest > testTopicCreation() 
PASSED
[2021-07-14T04:13:52.216Z] 
[2021-07-14T04:13:52.216Z] ControllerIntegrationTest > 
testControllerFeatureZNodeSetupWhenFeatureVersioningIsDisabledWithEnabledExistingFeatureZNode()
 STARTED
[2021-07-14T04:13:54.308Z] 
[2021-07-14T04:13:54.308Z] ControllerIntegrationTest > 
testControllerFeatureZNodeSetupWhenFeatureVersioningIsDisabledWithEnabledExistingFeatureZNode()
 PASSED
[2021-07-14T04:13:54.308Z] 
[2021-07-14T04:13:54.308Z] ControllerIntegrationTest > 
testControllerMoveOnTopicDeletion() STARTED
[2021-07-14T04:13:57.847Z] 
[2021-07-14T04:13:57.847Z] ControllerIntegrationTest > 
testControllerMoveOnTopicDeletion() PASSED
[2021-07-14T04:13:57.847Z] 
[2021-07-14T04:13:57.847Z] ControllerIntegrationTest > 
testPartitionReassignment() STARTED
[2021-07-14T04:14:01.027Z] 
[2021-07-14T04:14:01.027Z] ControllerIntegrationTest > 
testPartitionReassignment() PASSED
[2021-07-14T04:14:01.027Z] 
[2021-07-14T04:14:01.027Z] ControllerIntegrationTest > 
testTopicIdPersistsThroughControllerRestart() STARTED
[2021-07-14T04:14:05.550Z] 
[2021-07-14T04:14:05.550Z] ControllerIntegrationTest > 
testTopicIdPersistsThroughControllerRestart() PASSED
[2021-07-14T04:14:05.550Z] 
[2021-07-14T04:14:05.550Z] ControllerIntegrationTest > 
testTopicPartitionExpansion() STARTED
[2021-07-14T04:14:08.788Z] 
[2021-07-14T04:14:08.788Z] ControllerIntegrationTest > 
testTopicPartitionExpansion() PASSED
[2021-07-14T04:14:08.788Z] 
[2021-07-14T04:14:08.788Z] ControllerIntegrationTest > 
testTopicIdsAreNotAdded() STARTED
[2021-07-14T04:14:11.852Z] 
[2021-07-14T04:14:11.852Z] ControllerIntegrationTest > 
testTopicIdsAreNotAdded() PASSED
[2021-07-14T04:14:11.852Z] 
[2021-07-14T04:14:11.852Z] ControllerIntegrationTest > 
testControllerMoveIncrementsControllerEpoch() STARTED
[2021-07-14T04:14:16.325Z] 
[2021-07-14T04:14:16.325Z] ControllerIntegrationTest > 
testControllerMoveIncrementsControllerEpoch() PASSED
[2021-07-14T04:14:16.325Z] 
[2021-07-14T04:14:16.325Z] ControllerIntegrationTest > testIdempotentAlterIsr() 
STARTED
[2021-07-14T04:14:19.502Z] 
[2021-07-14T04:14:19.502Z] ControllerIntegrationTest > testIdempotentAlterIsr() 
PASSED
[2021-07-14T04:14:19.502Z] 
[2021-07-14T04:14:19.502Z] ControllerIntegrationTest > 
testLeaderAndIsrWhenEntireIsrOfflineAndUncleanLeaderElectionEnabled() STARTED
[2021-07-14T04:14:24.764Z] 
[2021-07-14T04:14:24.764Z] ControllerIntegrationTest > 
testLeaderAndIsrWhenEntireIsrOfflineAndUncleanLeaderElectionEnabled() PASSED
[2021-07-14T04:14:24.764Z] 
[2021-07-14T04:14:24.764Z] ControllerIntegrationTest > 
testControllerMoveOnPartitionReassignment() STARTED
[2021-07-14T04:14:29.048Z] 
[2021-07-14T04:14:29.048Z] ControllerIntegrationTest > 
testControllerMoveOnPartitionReassignment() PASSED
[2021-07-14T04:14:29.048Z] 
[2021-07-14T04:14:29.048Z] ControllerIntegrationTest > 
testControllerFeatureZNodeSetupWhenFeatureVersioningIsEnabledWithEnabledExistingFeatureZNode()
 START

Build failed in Jenkins: Kafka » Kafka Branch Builder » 2.8 #48

[Apache Jenkins Server]

See 


Changes:


--
[...truncated 464260 lines...]
[2021-07-14T06:02:45.569Z] 
[2021-07-14T06:02:45.569Z] ControllerIntegrationTest > 
testTopicIdCreatedOnUpgrade() STARTED
[2021-07-14T06:02:49.886Z] 
[2021-07-14T06:02:49.886Z] ControllerIntegrationTest > 
testTopicIdCreatedOnUpgrade() PASSED
[2021-07-14T06:02:49.886Z] 
[2021-07-14T06:02:49.886Z] ControllerIntegrationTest > 
testTopicIdMigrationAndHandling() STARTED
[2021-07-14T06:02:51.862Z] 
[2021-07-14T06:02:51.862Z] ControllerIntegrationTest > 
testTopicIdMigrationAndHandling() PASSED
[2021-07-14T06:02:51.862Z] 
[2021-07-14T06:02:51.862Z] KafkaZkClientTest > 
testZNodeChangeHandlerForDataChange() STARTED
[2021-07-14T06:02:51.862Z] 
[2021-07-14T06:02:51.862Z] KafkaZkClientTest > 
testZNodeChangeHandlerForDataChange() PASSED
[2021-07-14T06:02:51.862Z] 
[2021-07-14T06:02:51.862Z] KafkaZkClientTest > 
testCreateAndGetTopicPartitionStatesRaw() STARTED
[2021-07-14T06:02:51.862Z] 
[2021-07-14T06:02:51.862Z] KafkaZkClientTest > 
testCreateAndGetTopicPartitionStatesRaw() PASSED
[2021-07-14T06:02:51.862Z] 
[2021-07-14T06:02:51.862Z] KafkaZkClientTest > testLogDirGetters() STARTED
[2021-07-14T06:02:52.898Z] 
[2021-07-14T06:02:52.898Z] KafkaZkClientTest > testLogDirGetters() PASSED
[2021-07-14T06:02:52.898Z] 
[2021-07-14T06:02:52.898Z] KafkaZkClientTest > 
testSetGetAndDeletePartitionReassignment() STARTED
[2021-07-14T06:02:52.898Z] 
[2021-07-14T06:02:52.898Z] KafkaZkClientTest > 
testSetGetAndDeletePartitionReassignment() PASSED
[2021-07-14T06:02:52.898Z] 
[2021-07-14T06:02:52.898Z] KafkaZkClientTest > 
testIsrChangeNotificationsDeletion() STARTED
[2021-07-14T06:02:52.898Z] 
[2021-07-14T06:02:52.898Z] KafkaZkClientTest > 
testIsrChangeNotificationsDeletion() PASSED
[2021-07-14T06:02:52.898Z] 
[2021-07-14T06:02:52.898Z] KafkaZkClientTest > testGetDataAndVersion() STARTED
[2021-07-14T06:02:53.933Z] 
[2021-07-14T06:02:53.933Z] KafkaZkClientTest > testGetDataAndVersion() PASSED
[2021-07-14T06:02:53.933Z] 
[2021-07-14T06:02:53.933Z] KafkaZkClientTest > testGetChildren() STARTED
[2021-07-14T06:02:53.933Z] 
[2021-07-14T06:02:53.933Z] KafkaZkClientTest > testGetChildren() PASSED
[2021-07-14T06:02:53.933Z] 
[2021-07-14T06:02:53.933Z] KafkaZkClientTest > testSetAndGetConsumerOffset() 
STARTED
[2021-07-14T06:02:54.969Z] 
[2021-07-14T06:02:54.969Z] KafkaZkClientTest > testSetAndGetConsumerOffset() 
PASSED
[2021-07-14T06:02:54.969Z] 
[2021-07-14T06:02:54.969Z] KafkaZkClientTest > testClusterIdMethods() STARTED
[2021-07-14T06:02:54.969Z] 
[2021-07-14T06:02:54.969Z] KafkaZkClientTest > testClusterIdMethods() PASSED
[2021-07-14T06:02:54.969Z] 
[2021-07-14T06:02:54.969Z] KafkaZkClientTest > 
testEntityConfigManagementMethods() STARTED
[2021-07-14T06:02:54.969Z] 
[2021-07-14T06:02:54.969Z] KafkaZkClientTest > 
testEntityConfigManagementMethods() PASSED
[2021-07-14T06:02:54.969Z] 
[2021-07-14T06:02:54.969Z] KafkaZkClientTest > testUpdateLeaderAndIsr() STARTED
[2021-07-14T06:02:56.177Z] 
[2021-07-14T06:02:56.177Z] KafkaZkClientTest > testUpdateLeaderAndIsr() PASSED
[2021-07-14T06:02:56.177Z] 
[2021-07-14T06:02:56.177Z] KafkaZkClientTest > testUpdateBrokerInfo() STARTED
[2021-07-14T06:02:56.177Z] 
[2021-07-14T06:02:56.177Z] KafkaZkClientTest > testUpdateBrokerInfo() PASSED
[2021-07-14T06:02:56.177Z] 
[2021-07-14T06:02:56.177Z] KafkaZkClientTest > testCreateRecursive() STARTED
[2021-07-14T06:02:57.395Z] 
[2021-07-14T06:02:57.396Z] KafkaZkClientTest > testCreateRecursive() PASSED
[2021-07-14T06:02:57.396Z] 
[2021-07-14T06:02:57.396Z] KafkaZkClientTest > testGetConsumerOffsetNoData() 
STARTED
[2021-07-14T06:02:57.396Z] 
[2021-07-14T06:02:57.396Z] KafkaZkClientTest > testGetConsumerOffsetNoData() 
PASSED
[2021-07-14T06:02:57.396Z] 
[2021-07-14T06:02:57.396Z] KafkaZkClientTest > testDeleteTopicPathMethods() 
STARTED
[2021-07-14T06:02:57.396Z] 
[2021-07-14T06:02:57.396Z] KafkaZkClientTest > testDeleteTopicPathMethods() 
PASSED
[2021-07-14T06:02:57.396Z] 
[2021-07-14T06:02:57.396Z] KafkaZkClientTest > testSetTopicPartitionStatesRaw() 
STARTED
[2021-07-14T06:02:57.396Z] 
[2021-07-14T06:02:57.396Z] KafkaZkClientTest > testSetTopicPartitionStatesRaw() 
PASSED
[2021-07-14T06:02:57.396Z] 
[2021-07-14T06:02:57.396Z] KafkaZkClientTest > testAclManagementMethods() 
STARTED
[2021-07-14T06:02:57.396Z] 
[2021-07-14T06:02:57.396Z] KafkaZkClientTest > testAclManagementMethods() PASSED
[2021-07-14T06:02:57.396Z] 
[2021-07-14T06:02:57.396Z] KafkaZkClientTest > 
testPreferredReplicaElectionMethods() STARTED
[2021-07-14T06:02:58.538Z] 
[2021-07-14T06:02:58.538Z] KafkaZkClientTest > 
testPreferredReplicaElectionMethods() PASSED
[2021-07-14T06:02:58.538Z] 
[2021-07-14T06:02:58.538Z] KafkaZkClientTest > testPropagateLogDir() STARTED
[2021-07-14T06:02:58.538Z] 
[2021-07-14T06:02:58.538Z] KafkaZkClientTest > testPropagateLogDir() PASSED
[2021-07-14T06:02:58.538Z] 
[2021-07-14T06:02:58.538Z] Kafk

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.0 #25

[Apache Jenkins Server]

See 


Changes:


--
[...truncated 211916 lines...]
[2021-07-14T06:21:37.022Z] > Task :connect:json:javadocJar
[2021-07-14T06:21:37.022Z] > Task :streams:jar UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :storage:compileJava UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :clients:compileTestJava UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :clients:testClasses UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :streams:test-utils:compileJava UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :metadata:compileJava UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :metadata:classes UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :core:compileJava NO-SOURCE
[2021-07-14T06:21:37.022Z] > Task 
:streams:generateMetadataFileForMavenJavaPublication
[2021-07-14T06:21:37.022Z] > Task :connect:json:compileTestJava UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :connect:json:testClasses UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :raft:compileTestJava UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :raft:testClasses UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :connect:json:testJar
[2021-07-14T06:21:37.022Z] > Task :connect:json:testSrcJar
[2021-07-14T06:21:37.022Z] > Task 
:clients:generateMetadataFileForMavenJavaPublication
[2021-07-14T06:21:37.022Z] > Task :metadata:compileTestJava UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :metadata:testClasses UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :core:compileScala UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :core:classes UP-TO-DATE
[2021-07-14T06:21:37.022Z] > Task :core:compileTestJava NO-SOURCE
[2021-07-14T06:21:37.960Z] > Task :core:compileTestScala UP-TO-DATE
[2021-07-14T06:21:37.960Z] > Task :core:testClasses UP-TO-DATE
[2021-07-14T06:21:41.729Z] > Task :connect:api:javadoc
[2021-07-14T06:21:41.729Z] > Task :connect:api:copyDependantLibs UP-TO-DATE
[2021-07-14T06:21:41.729Z] > Task :connect:api:jar UP-TO-DATE
[2021-07-14T06:21:41.729Z] > Task 
:connect:api:generateMetadataFileForMavenJavaPublication
[2021-07-14T06:21:41.729Z] > Task :connect:json:copyDependantLibs UP-TO-DATE
[2021-07-14T06:21:41.729Z] > Task :connect:json:jar UP-TO-DATE
[2021-07-14T06:21:41.729Z] > Task 
:connect:json:generateMetadataFileForMavenJavaPublication
[2021-07-14T06:21:41.729Z] > Task :connect:api:javadocJar
[2021-07-14T06:21:41.729Z] > Task 
:connect:json:publishMavenJavaPublicationToMavenLocal
[2021-07-14T06:21:41.729Z] > Task :connect:json:publishToMavenLocal
[2021-07-14T06:21:41.729Z] > Task :connect:api:compileTestJava UP-TO-DATE
[2021-07-14T06:21:41.729Z] > Task :connect:api:testClasses UP-TO-DATE
[2021-07-14T06:21:41.729Z] > Task :connect:api:testJar
[2021-07-14T06:21:41.729Z] > Task :connect:api:testSrcJar
[2021-07-14T06:21:41.729Z] > Task 
:connect:api:publishMavenJavaPublicationToMavenLocal
[2021-07-14T06:21:41.729Z] > Task :connect:api:publishToMavenLocal
[2021-07-14T06:21:43.483Z] > Task :streams:javadoc
[2021-07-14T06:21:43.483Z] > Task :streams:javadocJar
[2021-07-14T06:21:43.483Z] > Task :streams:compileTestJava UP-TO-DATE
[2021-07-14T06:21:43.483Z] > Task :streams:testClasses UP-TO-DATE
[2021-07-14T06:21:44.419Z] > Task :streams:testJar
[2021-07-14T06:21:44.419Z] > Task :streams:testSrcJar
[2021-07-14T06:21:44.419Z] > Task 
:streams:publishMavenJavaPublicationToMavenLocal
[2021-07-14T06:21:44.419Z] > Task :streams:publishToMavenLocal
[2021-07-14T06:21:45.356Z] > Task :clients:javadoc
[2021-07-14T06:21:46.293Z] > Task :clients:javadocJar
[2021-07-14T06:21:46.293Z] 
[2021-07-14T06:21:46.293Z] > Task :clients:srcJar
[2021-07-14T06:21:46.293Z] Execution optimizations have been disabled for task 
':clients:srcJar' to ensure correctness due to the following reasons:
[2021-07-14T06:21:46.293Z]   - Gradle detected a problem with the following 
location: 
'/home/jenkins/jenkins-agent/workspace/Kafka_kafka_3.0@2/clients/src/generated/java'.
 Reason: Task ':clients:srcJar' uses this output of task 
':clients:processMessages' without declaring an explicit or implicit 
dependency. This can lead to incorrect results being produced, depending on 
what order the tasks are executed. Please refer to 
https://docs.gradle.org/7.1.1/userguide/validation_problems.html#implicit_dependency
 for more details about this problem.
[2021-07-14T06:21:47.231Z] 
[2021-07-14T06:21:47.231Z] > Task :clients:testJar
[2021-07-14T06:21:48.078Z] > Task :clients:testSrcJar
[2021-07-14T06:21:48.078Z] > Task 
:clients:publishMavenJavaPublicationToMavenLocal
[2021-07-14T06:21:48.078Z] > Task :clients:publishToMavenLocal
[2021-07-14T06:21:48.078Z] 
[2021-07-14T06:21:48.078Z] Deprecated Gradle features were used in this build, 
making it incompatible with Gradle 8.0.
[2021-07-14T06:21:48.078Z] 
[2021-07-14T06:21:48.078Z] You can use '--warning-mode all' to show the 
individual deprecation warnings and determine if they come from your own 
scripts or plugins.
[2021-07-14T06:21:48.078Z] 
[2021-07-14T06:21:48.078Z] See 
https://

[jira] [Resolved] (KAFKA-10588) Rename kafka-console-consumer CLI command line arguments for KIP-629

[David Jacot (Jira)]

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

David Jacot resolved KAFKA-10588.
-
  Reviewer: David Jacot
Resolution: Fixed

> Rename kafka-console-consumer CLI command line arguments for KIP-629
> 
>
> Key: KAFKA-10588
> URL: https://issues.apache.org/jira/browse/KAFKA-10588
> Project: Kafka
>  Issue Type: Sub-task
>Reporter: Xavier Léauté
>Assignee: Omnia Ibrahim
>Priority: Blocker
> Fix For: 3.0.0
>
>




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

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #317

[Apache Jenkins Server]

See 


Changes:


--
[...truncated 212564 lines...]
[2021-07-14T06:29:46.900Z] > Task :raft:testClasses UP-TO-DATE
[2021-07-14T06:29:46.900Z] > Task :connect:json:testJar
[2021-07-14T06:29:46.900Z] > Task :connect:json:testSrcJar
[2021-07-14T06:29:46.900Z] > Task :metadata:compileTestJava UP-TO-DATE
[2021-07-14T06:29:46.900Z] > Task :metadata:testClasses UP-TO-DATE
[2021-07-14T06:29:46.900Z] > Task 
:clients:generateMetadataFileForMavenJavaPublication
[2021-07-14T06:29:46.900Z] > Task 
:clients:generatePomFileForMavenJavaPublication
[2021-07-14T06:29:47.841Z] 
[2021-07-14T06:29:47.841Z] > Task :streams:processMessages
[2021-07-14T06:29:47.841Z] Execution optimizations have been disabled for task 
':streams:processMessages' to ensure correctness due to the following reasons:
[2021-07-14T06:29:47.841Z]   - Gradle detected a problem with the following 
location: 
'/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk/streams/src/generated/java/org/apache/kafka/streams/internals/generated'.
 Reason: Task ':streams:srcJar' uses this output of task 
':streams:processMessages' without declaring an explicit or implicit 
dependency. This can lead to incorrect results being produced, depending on 
what order the tasks are executed. Please refer to 
https://docs.gradle.org/7.1.1/userguide/validation_problems.html#implicit_dependency
 for more details about this problem.
[2021-07-14T06:29:47.841Z] MessageGenerator: processed 1 Kafka message JSON 
files(s).
[2021-07-14T06:29:47.841Z] 
[2021-07-14T06:29:47.841Z] > Task :core:compileScala UP-TO-DATE
[2021-07-14T06:29:47.841Z] > Task :core:classes UP-TO-DATE
[2021-07-14T06:29:47.841Z] > Task :core:compileTestJava NO-SOURCE
[2021-07-14T06:29:47.841Z] > Task :streams:compileJava UP-TO-DATE
[2021-07-14T06:29:47.841Z] > Task :streams:classes UP-TO-DATE
[2021-07-14T06:29:47.841Z] > Task :streams:copyDependantLibs UP-TO-DATE
[2021-07-14T06:29:47.841Z] > Task :streams:jar UP-TO-DATE
[2021-07-14T06:29:47.841Z] > Task :streams:test-utils:compileJava UP-TO-DATE
[2021-07-14T06:29:47.841Z] > Task 
:streams:generateMetadataFileForMavenJavaPublication
[2021-07-14T06:29:47.841Z] > Task :core:compileTestScala UP-TO-DATE
[2021-07-14T06:29:47.841Z] > Task :core:testClasses UP-TO-DATE
[2021-07-14T06:29:52.184Z] > Task :connect:api:javadoc
[2021-07-14T06:29:52.184Z] > Task :connect:api:copyDependantLibs UP-TO-DATE
[2021-07-14T06:29:52.184Z] > Task :connect:api:jar UP-TO-DATE
[2021-07-14T06:29:52.184Z] > Task 
:connect:api:generateMetadataFileForMavenJavaPublication
[2021-07-14T06:29:52.184Z] > Task :connect:json:copyDependantLibs UP-TO-DATE
[2021-07-14T06:29:52.184Z] > Task :connect:json:jar UP-TO-DATE
[2021-07-14T06:29:52.184Z] > Task 
:connect:json:generateMetadataFileForMavenJavaPublication
[2021-07-14T06:29:52.184Z] > Task :connect:api:javadocJar
[2021-07-14T06:29:52.184Z] > Task 
:connect:json:publishMavenJavaPublicationToMavenLocal
[2021-07-14T06:29:52.184Z] > Task :connect:json:publishToMavenLocal
[2021-07-14T06:29:52.184Z] > Task :connect:api:compileTestJava UP-TO-DATE
[2021-07-14T06:29:52.184Z] > Task :connect:api:testClasses UP-TO-DATE
[2021-07-14T06:29:52.184Z] > Task :connect:api:testJar
[2021-07-14T06:29:52.184Z] > Task :connect:api:testSrcJar
[2021-07-14T06:29:52.184Z] > Task 
:connect:api:publishMavenJavaPublicationToMavenLocal
[2021-07-14T06:29:52.184Z] > Task :connect:api:publishToMavenLocal
[2021-07-14T06:29:56.061Z] > Task :streams:javadoc
[2021-07-14T06:29:56.061Z] > Task :streams:javadocJar
[2021-07-14T06:29:57.018Z] > Task :streams:compileTestJava UP-TO-DATE
[2021-07-14T06:29:57.019Z] > Task :streams:testClasses UP-TO-DATE
[2021-07-14T06:29:57.019Z] > Task :streams:testJar
[2021-07-14T06:29:57.964Z] > Task :streams:testSrcJar
[2021-07-14T06:29:57.964Z] > Task 
:streams:publishMavenJavaPublicationToMavenLocal
[2021-07-14T06:29:57.964Z] > Task :streams:publishToMavenLocal
[2021-07-14T06:29:58.897Z] > Task :clients:javadoc
[2021-07-14T06:29:58.897Z] > Task :clients:javadocJar
[2021-07-14T06:29:59.905Z] 
[2021-07-14T06:29:59.905Z] > Task :clients:srcJar
[2021-07-14T06:29:59.905Z] Execution optimizations have been disabled for task 
':clients:srcJar' to ensure correctness due to the following reasons:
[2021-07-14T06:29:59.905Z]   - Gradle detected a problem with the following 
location: 
'/home/jenkins/jenkins-agent/workspace/Kafka_kafka_trunk/clients/src/generated/java'.
 Reason: Task ':clients:srcJar' uses this output of task 
':clients:processMessages' without declaring an explicit or implicit 
dependency. This can lead to incorrect results being produced, depending on 
what order the tasks are executed. Please refer to 
https://docs.gradle.org/7.1.1/userguide/validation_problems.html#implicit_dependency
 for more details about this problem.
[2021-07-14T06:30:00.940Z] 
[2021-07-14T06:30:00.940Z] > Task :clients:testJar
[2021-07-14T06:30:01.944Z] > Tas

[jira] [Resolved] (KAFKA-10589) Rename kafka-replica-verification CLI command line arguments for KIP-629

[David Jacot (Jira)]

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

David Jacot resolved KAFKA-10589.
-
  Reviewer: David Jacot
Resolution: Fixed

> Rename kafka-replica-verification CLI command line arguments for KIP-629
> 
>
> Key: KAFKA-10589
> URL: https://issues.apache.org/jira/browse/KAFKA-10589
> Project: Kafka
>  Issue Type: Sub-task
>Reporter: Xavier Léauté
>Assignee: Omnia Ibrahim
>Priority: Blocker
> Fix For: 3.0.0
>
>




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

[jira] [Resolved] (KAFKA-10201) Update codebase to use more inclusive terms

[David Jacot (Jira)]

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

David Jacot resolved KAFKA-10201.
-
Resolution: Fixed

> Update codebase to use more inclusive terms
> ---
>
> Key: KAFKA-10201
> URL: https://issues.apache.org/jira/browse/KAFKA-10201
> Project: Kafka
>  Issue Type: Improvement
>Reporter: Xavier Léauté
>Priority: Major
> Fix For: 3.0.0
>
>
> see the corresponding KIP 
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-629:+Use+racially+neutral+terms+in+our+codebase



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